public interface ServerSession extends SecurityAuth
Modifier and Type | Method and Description |
---|---|
void |
acknowledge(long consumerID,
long messageID) |
void |
addMetaData(String key,
String data) |
boolean |
addUniqueMetaData(String key,
String data) |
void |
close(boolean failed) |
void |
closeConsumer(long consumerID) |
void |
commit() |
ServerConsumer |
createConsumer(long consumerID,
SimpleString queueName,
SimpleString filterString,
boolean browseOnly) |
Queue |
createQueue(SimpleString address,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable) |
void |
createSharedQueue(SimpleString address,
SimpleString name,
boolean durable,
SimpleString filterString) |
void |
deleteQueue(SimpleString name) |
void |
describeProducersInfo(JSONArray objs)
Add all the producers detail to the JSONArray object.
|
BindingQueryResult |
executeBindingQuery(SimpleString address) |
QueueQueryResult |
executeQueueQuery(SimpleString name) |
void |
expire(long consumerID,
long messageID) |
void |
forceConsumerDelivery(long consumerID,
long sequence) |
Object |
getConnectionID() |
long |
getCreationTime() |
Transaction |
getCurrentTransaction() |
List<MessageReference> |
getInTXMessagesForConsumer(long consumerId) |
String |
getLastSentMessageID(String address) |
String |
getMetaData(String key) |
int |
getMinLargeMessageSize() |
String |
getName() |
QueueCreator |
getQueueCreator() |
RemotingConnection |
getRemotingConnection() |
Set<ServerConsumer> |
getServerConsumers() |
OperationContext |
getSessionContext() |
String[] |
getTargetAddresses() |
void |
individualAcknowledge(long consumerID,
long messageID) |
void |
individualCancel(long consumerID,
long messageID,
boolean failed) |
void |
markTXFailed(Throwable e) |
void |
receiveConsumerCredits(long consumerID,
int credits) |
boolean |
removeConsumer(long consumerID) |
void |
requestProducerCredits(SimpleString address,
int credits) |
void |
rollback(boolean considerLastMessageAsDelivered) |
void |
send(ServerMessage message,
boolean direct) |
void |
sendContinuations(int packetSize,
long totalBodySize,
byte[] body,
boolean continues) |
void |
sendLarge(MessageInternal msg) |
void |
setTransferring(boolean transferring) |
void |
start() |
void |
stop() |
void |
waitContextCompletion() |
void |
xaCommit(Xid xid,
boolean onePhase) |
void |
xaEnd(Xid xid) |
void |
xaFailed(Xid xid) |
void |
xaForget(Xid xid) |
List<Xid> |
xaGetInDoubtXids() |
int |
xaGetTimeout() |
void |
xaJoin(Xid xid) |
void |
xaPrepare(Xid xid) |
void |
xaResume(Xid xid) |
void |
xaRollback(Xid xid) |
void |
xaSetTimeout(int timeout) |
void |
xaStart(Xid xid) |
void |
xaSuspend() |
getPassword, getUsername
String getName()
int getMinLargeMessageSize()
Object getConnectionID()
RemotingConnection getRemotingConnection()
void individualAcknowledge(long consumerID, long messageID) throws Exception
Exception
void individualCancel(long consumerID, long messageID, boolean failed) throws Exception
Exception
void markTXFailed(Throwable e)
QueueCreator getQueueCreator()
int xaGetTimeout()
void xaSetTimeout(int timeout)
void start()
void stop()
Queue createQueue(SimpleString address, SimpleString name, SimpleString filterString, boolean temporary, boolean durable) throws Exception
Exception
void deleteQueue(SimpleString name) throws Exception
Exception
ServerConsumer createConsumer(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly) throws Exception
Exception
QueueQueryResult executeQueueQuery(SimpleString name) throws Exception
Exception
BindingQueryResult executeBindingQuery(SimpleString address) throws Exception
Exception
void receiveConsumerCredits(long consumerID, int credits) throws Exception
Exception
void sendContinuations(int packetSize, long totalBodySize, byte[] body, boolean continues) throws Exception
Exception
void send(ServerMessage message, boolean direct) throws Exception
Exception
void sendLarge(MessageInternal msg) throws Exception
Exception
void forceConsumerDelivery(long consumerID, long sequence) throws Exception
Exception
void requestProducerCredits(SimpleString address, int credits) throws Exception
Exception
void setTransferring(boolean transferring)
Set<ServerConsumer> getServerConsumers()
String[] getTargetAddresses()
void describeProducersInfo(JSONArray objs) throws Exception
objs
- Exception
long getCreationTime()
OperationContext getSessionContext()
Transaction getCurrentTransaction()
void createSharedQueue(SimpleString address, SimpleString name, boolean durable, SimpleString filterString) throws Exception
Exception
List<MessageReference> getInTXMessagesForConsumer(long consumerId)
Copyright © 2016 JBoss by Red Hat. All rights reserved.