public final class CoreSessionCallback extends Object implements SessionCallback
Constructor and Description |
---|
CoreSessionCallback(String name,
ProtocolManager protocolManager,
Channel channel) |
Modifier and Type | Method and Description |
---|---|
void |
addReadyListener(ReadyListener listener) |
void |
closed() |
void |
disconnect(long consumerId,
String queueName) |
void |
removeReadyListener(ReadyListener listener) |
int |
sendLargeMessage(ServerMessage message,
long consumerID,
long bodySize,
int deliveryCount) |
int |
sendLargeMessageContinuation(long consumerID,
byte[] body,
boolean continues,
boolean requiresResponse) |
int |
sendMessage(ServerMessage message,
long consumerID,
int deliveryCount) |
void |
sendProducerCreditsFailMessage(int credits,
SimpleString address) |
void |
sendProducerCreditsMessage(int credits,
SimpleString address) |
public CoreSessionCallback(String name, ProtocolManager protocolManager, Channel channel)
public int sendLargeMessage(ServerMessage message, long consumerID, long bodySize, int deliveryCount)
sendLargeMessage
in interface SessionCallback
public int sendLargeMessageContinuation(long consumerID, byte[] body, boolean continues, boolean requiresResponse)
sendLargeMessageContinuation
in interface SessionCallback
public int sendMessage(ServerMessage message, long consumerID, int deliveryCount)
sendMessage
in interface SessionCallback
public void sendProducerCreditsMessage(int credits, SimpleString address)
sendProducerCreditsMessage
in interface SessionCallback
public void sendProducerCreditsFailMessage(int credits, SimpleString address)
sendProducerCreditsFailMessage
in interface SessionCallback
public void closed()
closed
in interface SessionCallback
public void addReadyListener(ReadyListener listener)
addReadyListener
in interface SessionCallback
public void removeReadyListener(ReadyListener listener)
removeReadyListener
in interface SessionCallback
public void disconnect(long consumerId, String queueName)
disconnect
in interface SessionCallback
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.