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) |
ServerConsumer |
createConsumer(long consumerID,
SimpleString queueName,
SimpleString filterString,
boolean browseOnly,
boolean supportLargeMessage,
Integer credits) |
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(javax.json.JsonArrayBuilder objs)
Add all the producers detail to the JSONArray object.
|
void |
disableSecurity() |
void |
enableSecurity()
Certain protocols may create an internal session that shouldn't go through security checks.
|
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() |
String |
getValidatedUser() |
void |
individualAcknowledge(long consumerID,
long messageID) |
void |
individualCancel(long consumerID,
long messageID,
boolean failed) |
boolean |
isClosed() |
ServerConsumer |
locateConsumer(long consumerID) |
void |
markTXFailed(Throwable e) |
Transaction |
newTransaction() |
void |
receiveConsumerCredits(long consumerID,
int credits) |
boolean |
removeConsumer(long consumerID) |
void |
requestProducerCredits(SimpleString address,
int credits) |
void |
resetTX(Transaction transaction)
To be used by protocol heads that needs to control the transaction outside the session context.
|
void |
rollback(boolean considerLastMessageAsDelivered) |
RoutingStatus |
send(ServerMessage message,
boolean direct) |
RoutingStatus |
send(ServerMessage message,
boolean direct,
boolean noAutoCreateQueue) |
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()
void enableSecurity()
void disableSecurity()
RemotingConnection getRemotingConnection()
getRemotingConnection
in interface SecurityAuth
Transaction newTransaction()
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()
void resetTX(Transaction transaction)
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
ServerConsumer createConsumer(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage, Integer credits) 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
RoutingStatus send(ServerMessage message, boolean direct, boolean noAutoCreateQueue) throws Exception
Exception
RoutingStatus 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(javax.json.JsonArrayBuilder objs) throws Exception
objs
- Exception
long getCreationTime()
OperationContext getSessionContext()
Transaction getCurrentTransaction()
ServerConsumer locateConsumer(long consumerID) throws Exception
Exception
boolean isClosed()
void createSharedQueue(SimpleString address, SimpleString name, boolean durable, SimpleString filterString) throws Exception
Exception
List<MessageReference> getInTXMessagesForConsumer(long consumerId)
String getValidatedUser()
Copyright © 2016 The Apache Software Foundation. All rights reserved.