public class StompSession extends Object implements SessionCallback
Modifier and Type | Method and Description |
---|---|
void |
acknowledge(String messageID,
String subscriptionID) |
void |
addReadyListener(ReadyListener listener) |
void |
addSubscription(long consumerID,
String subscriptionID,
String clientID,
String durableSubscriptionName,
String destination,
String selector,
String ack) |
void |
closed() |
RemotingConnection |
getConnection() |
OperationContext |
getContext() |
ServerSession |
getSession() |
boolean |
isNoLocal() |
void |
removeReadyListener(ReadyListener listener) |
void |
sendInternal(ServerMessageImpl message,
boolean direct) |
void |
sendInternalLarge(ServerMessageImpl message,
boolean direct) |
int |
sendLargeMessage(ServerMessage msg,
long consumerID,
long bodySize,
int deliveryCount) |
int |
sendLargeMessageContinuation(long consumerID,
byte[] body,
boolean continues,
boolean requiresResponse) |
int |
sendMessage(ServerMessage serverMessage,
long consumerID,
int deliveryCount) |
void |
sendProducerCreditsFailMessage(int credits,
SimpleString address) |
void |
sendProducerCreditsMessage(int credits,
SimpleString address) |
void |
setNoLocal(boolean noLocal) |
boolean |
unsubscribe(String id,
String durableSubscriptionName) |
public ServerSession getSession()
public void sendProducerCreditsMessage(int credits, SimpleString address)
sendProducerCreditsMessage
in interface SessionCallback
public void sendProducerCreditsFailMessage(int credits, SimpleString address)
sendProducerCreditsFailMessage
in interface SessionCallback
public int sendMessage(ServerMessage serverMessage, long consumerID, int deliveryCount)
sendMessage
in interface SessionCallback
public int sendLargeMessageContinuation(long consumerID, byte[] body, boolean continues, boolean requiresResponse)
sendLargeMessageContinuation
in interface SessionCallback
public int sendLargeMessage(ServerMessage msg, long consumerID, long bodySize, int deliveryCount)
sendLargeMessage
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 acknowledge(String messageID, String subscriptionID) throws Exception
Exception
public void addSubscription(long consumerID, String subscriptionID, String clientID, String durableSubscriptionName, String destination, String selector, String ack) throws Exception
Exception
public boolean unsubscribe(String id, String durableSubscriptionName) throws Exception
Exception
public RemotingConnection getConnection()
public OperationContext getContext()
public boolean isNoLocal()
public void setNoLocal(boolean noLocal)
public void sendInternal(ServerMessageImpl message, boolean direct) throws Exception
Exception
public void sendInternalLarge(ServerMessageImpl message, boolean direct) throws Exception
Exception
Copyright © 2013 JBoss, a division of Red Hat. All rights reserved.