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 |
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 |
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 closed()
closed
in interface SessionCallback
public void addReadyListener(ReadyListener listener)
addReadyListener
in interface SessionCallback
public void removeReadyListener(ReadyListener listener)
removeReadyListener
in interface SessionCallback
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.