public interface ServerSession extends SecurityAuth
Modifier and Type | Method and Description |
---|---|
List<Long> |
acknowledge(long consumerID,
long messageID) |
void |
addCloseable(Closeable closeable) |
void |
addLingerConsumer(ServerConsumer consumer) |
void |
addMetaData(String key,
String data) |
void |
addProducer(ServerProducer serverProducer) |
boolean |
addUniqueMetaData(String key,
String data) |
void |
close(boolean failed) |
void |
closeConsumer(long consumerID) |
void |
commit() |
AddressInfo |
createAddress(AddressInfo addressInfo,
boolean autoCreated) |
AddressInfo |
createAddress(SimpleString address,
EnumSet<RoutingType> routingTypes,
boolean autoCreated) |
AddressInfo |
createAddress(SimpleString address,
RoutingType routingType,
boolean autoCreated) |
ServerConsumer |
createConsumer(long consumerID,
SimpleString queueName,
SimpleString filterString,
boolean browseOnly) |
ServerConsumer |
createConsumer(long consumerID,
SimpleString queueName,
SimpleString filterString,
boolean browseOnly,
boolean supportLargeMessage,
Integer credits) |
ServerConsumer |
createConsumer(long consumerID,
SimpleString queueName,
SimpleString filterString,
int priority,
boolean browseOnly,
boolean supportLargeMessage,
Integer credits) |
Queue |
createQueue(AddressInfo address,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable)
Deprecated.
|
Queue |
createQueue(AddressInfo addressInfo,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable,
boolean autoCreated)
Deprecated.
|
Queue |
createQueue(AddressInfo addressInfo,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable,
Boolean exclusive,
Boolean lastValue,
boolean autoCreated)
Deprecated.
|
Queue |
createQueue(QueueConfiguration queueConfiguration)
This method invokes
ActiveMQServer.createQueue(QueueConfiguration) with a few client-specific additions: |
Queue |
createQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean temporary,
boolean durable)
Deprecated.
|
Queue |
createQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean temporary,
boolean durable,
boolean autoCreated)
Deprecated.
|
Queue |
createQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean temporary,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
boolean autoCreated)
Deprecated.
|
Queue |
createQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean temporary,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue,
boolean autoCreated)
Deprecated.
|
Queue |
createQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean temporary,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
Boolean lastValue,
SimpleString lastValueKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
boolean autoCreated)
Deprecated.
|
Queue |
createQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean temporary,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
SimpleString groupFirstKey,
Boolean lastValue,
SimpleString lastValueKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
boolean autoCreated)
Deprecated.
|
Queue |
createQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean temporary,
boolean durable,
int maxConsumers,
boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
SimpleString groupFirstKey,
Boolean lastValue,
SimpleString lastValueKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
boolean autoCreated,
Long ringSize)
Deprecated.
|
Queue |
createQueue(SimpleString address,
SimpleString name,
SimpleString filterString,
boolean temporary,
boolean durable)
Deprecated.
|
void |
createSharedQueue(QueueConfiguration queueConfiguration) |
void |
createSharedQueue(SimpleString address,
SimpleString name,
boolean durable,
SimpleString filterString)
Deprecated.
|
void |
createSharedQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
boolean durable,
SimpleString filterString)
Deprecated.
|
void |
createSharedQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean durable,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean lastValue)
Deprecated.
|
void |
createSharedQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean durable,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
Boolean lastValue,
SimpleString lastValueKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount)
Deprecated.
|
void |
createSharedQueue(SimpleString address,
SimpleString name,
RoutingType routingType,
SimpleString filterString,
boolean durable,
Integer maxConsumers,
Boolean purgeOnNoConsumers,
Boolean exclusive,
Boolean groupRebalance,
Integer groupBuckets,
SimpleString groupFirstKey,
Boolean lastValue,
SimpleString lastValueKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount)
Deprecated.
|
void |
deleteQueue(SimpleString name) |
void |
describeProducersInfo(JsonArrayBuilder objs)
Add all the producers detail to the JSONArray object.
|
void |
disableSecurity() |
RoutingStatus |
doSend(Transaction tx,
Message msg,
SimpleString originalAddress,
boolean direct,
boolean noAutoCreateQueue) |
RoutingStatus |
doSend(Transaction tx,
Message msg,
SimpleString originalAddress,
boolean direct,
boolean noAutoCreateQueue,
RoutingContext routingContext) |
void |
enableSecurity()
Certain protocols may create an internal session that shouldn't go through security checks.
|
AddressQueryResult |
executeAddressQuery(SimpleString name) |
BindingQueryResult |
executeBindingQuery(SimpleString address) |
QueueQueryResult |
executeQueueQuery(SimpleString name) |
void |
expire(long consumerID,
long messageID) |
void |
forceConsumerDelivery(long consumerID,
long sequence) |
AddressInfo |
getAddress(SimpleString address) |
AddressInfo |
getAddressAndRoutingType(AddressInfo addressInfo)
Get the canonical (i.e.
|
Pair<SimpleString,EnumSet<RoutingType>> |
getAddressAndRoutingTypes(SimpleString address,
EnumSet<RoutingType> defaultRoutingTypes)
Get the canonical (i.e.
|
Object |
getConnectionID() |
int |
getConsumerCount() |
long |
getCreationTime() |
Transaction |
getCurrentTransaction() |
String |
getDefaultAddress() |
int |
getDefaultConsumerWindowSize(SimpleString address) |
List<MessageReference> |
getInTxLingerMessages() |
List<MessageReference> |
getInTXMessagesForConsumer(long consumerId) |
String |
getLastSentMessageID(String address) |
SimpleString |
getMatchingQueue(SimpleString address,
RoutingType routingType) |
SimpleString |
getMatchingQueue(SimpleString address,
SimpleString queueName,
RoutingType routingType) |
Map<String,String> |
getMetaData() |
String |
getMetaData(String key) |
int |
getMinLargeMessageSize() |
String |
getName() |
SimpleString |
getPrefix(SimpleString address)
Get the prefix (if it exists) from the address based on the prefixes provided to the ServerSession constructor.
|
int |
getProducerCount() |
RemotingConnection |
getRemotingConnection() |
RoutingType |
getRoutingTypeFromPrefix(SimpleString address,
RoutingType defaultRoutingType) |
Set<ServerConsumer> |
getServerConsumers() |
Map<String,ServerProducer> |
getServerProducers() |
OperationContext |
getSessionContext() |
Executor |
getSessionExecutor() |
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) |
SimpleString |
removePrefix(SimpleString address)
Strip the prefix (if it exists) from the address based on the prefixes provided to the ServerSession constructor.
|
void |
removeProducer(String ID) |
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(Message message,
boolean direct) |
RoutingStatus |
send(Message message,
boolean direct,
boolean noAutoCreateQueue) |
RoutingStatus |
send(Transaction tx,
Message message,
boolean direct,
boolean noAutoCreateQueue) |
RoutingStatus |
send(Transaction tx,
Message message,
boolean direct,
boolean noAutoCreateQueue,
RoutingContext routingContext) |
void |
setTransferring(boolean transferring) |
void |
start() |
void |
stop() |
String |
toManagementString() |
void |
transferConnection(RemotingConnection newConnection) |
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, getSecurityDomain, getUsername
String getName()
int getMinLargeMessageSize()
Object getConnectionID()
Executor getSessionExecutor()
void enableSecurity()
void disableSecurity()
RemotingConnection getRemotingConnection()
getRemotingConnection
in interface SecurityAuth
void transferConnection(RemotingConnection newConnection)
Transaction newTransaction()
List<Long> acknowledge(long consumerID, long messageID) throws Exception
Exception
void individualAcknowledge(long consumerID, long messageID) throws Exception
Exception
void individualCancel(long consumerID, long messageID, boolean failed) throws Exception
Exception
void markTXFailed(Throwable e)
int xaGetTimeout()
void xaSetTimeout(int timeout)
void start()
void stop()
void addCloseable(Closeable closeable)
ServerConsumer createConsumer(long consumerID, SimpleString queueName, SimpleString filterString, int priority, boolean browseOnly, boolean supportLargeMessage, Integer credits) throws Exception
Exception
void resetTX(Transaction transaction)
@Deprecated Queue createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable) throws Exception
Exception
@Deprecated Queue createQueue(AddressInfo address, SimpleString name, SimpleString filterString, boolean temporary, boolean durable) throws Exception
Exception
@Deprecated Queue createQueue(SimpleString address, SimpleString name, SimpleString filterString, boolean temporary, boolean durable) throws Exception
address
- name
- filterString
- temporary
- durable
- Exception
@Deprecated Queue createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreated) throws Exception
Exception
@Deprecated Queue createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue, boolean autoCreated) throws Exception
Exception
@Deprecated Queue createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreated) throws Exception
Exception
@Deprecated Queue createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreated) throws Exception
Exception
@Deprecated Queue createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreated, Long ringSize) throws Exception
Exception
@Deprecated Queue createQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean temporary, boolean durable, boolean autoCreated) throws Exception
Exception
@Deprecated Queue createQueue(AddressInfo addressInfo, SimpleString name, SimpleString filterString, boolean temporary, boolean durable, boolean autoCreated) throws Exception
Exception
@Deprecated Queue createQueue(AddressInfo addressInfo, SimpleString name, SimpleString filterString, boolean temporary, boolean durable, Boolean exclusive, Boolean lastValue, boolean autoCreated) throws Exception
Exception
Queue createQueue(QueueConfiguration queueConfiguration) throws Exception
ActiveMQServer.createQueue(QueueConfiguration)
with a few client-specific additions:
queueConfiguration
- the configuration to use when creating the queueQueue
instance that was createdException
AddressInfo createAddress(SimpleString address, EnumSet<RoutingType> routingTypes, boolean autoCreated) throws Exception
Exception
AddressInfo createAddress(SimpleString address, RoutingType routingType, boolean autoCreated) throws Exception
Exception
AddressInfo createAddress(AddressInfo addressInfo, boolean autoCreated) 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
AddressQueryResult executeAddressQuery(SimpleString name) throws Exception
Exception
BindingQueryResult executeBindingQuery(SimpleString address) throws Exception
Exception
void receiveConsumerCredits(long consumerID, int credits) throws Exception
Exception
RoutingStatus send(Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue) throws Exception
Exception
RoutingStatus send(Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, RoutingContext routingContext) throws Exception
Exception
RoutingStatus doSend(Transaction tx, Message msg, SimpleString originalAddress, boolean direct, boolean noAutoCreateQueue) throws Exception
Exception
RoutingStatus doSend(Transaction tx, Message msg, SimpleString originalAddress, boolean direct, boolean noAutoCreateQueue, RoutingContext routingContext) throws Exception
Exception
RoutingStatus send(Message message, boolean direct, boolean noAutoCreateQueue) throws Exception
Exception
RoutingStatus send(Message message, boolean direct) 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()
boolean addUniqueMetaData(String key, String data) throws Exception
Exception
String[] getTargetAddresses()
void describeProducersInfo(JsonArrayBuilder objs) throws Exception
objs
- Exception
long getCreationTime()
OperationContext getSessionContext()
Transaction getCurrentTransaction()
ServerConsumer locateConsumer(long consumerID) throws Exception
Exception
boolean isClosed()
@Deprecated void createSharedQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue) throws Exception
Exception
@Deprecated void createSharedQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount) throws Exception
Exception
@Deprecated void createSharedQueue(SimpleString address, SimpleString name, RoutingType routingType, SimpleString filterString, boolean durable, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount) throws Exception
Exception
@Deprecated void createSharedQueue(SimpleString address, SimpleString name, RoutingType routingType, boolean durable, SimpleString filterString) throws Exception
Exception
@Deprecated void createSharedQueue(SimpleString address, SimpleString name, boolean durable, SimpleString filterString) throws Exception
Exception
void createSharedQueue(QueueConfiguration queueConfiguration) throws Exception
Exception
List<MessageReference> getInTXMessagesForConsumer(long consumerId)
List<MessageReference> getInTxLingerMessages()
void addLingerConsumer(ServerConsumer consumer)
String getValidatedUser()
SimpleString getMatchingQueue(SimpleString address, RoutingType routingType) throws Exception
Exception
SimpleString getMatchingQueue(SimpleString address, SimpleString queueName, RoutingType routingType) throws Exception
Exception
AddressInfo getAddress(SimpleString address)
SimpleString removePrefix(SimpleString address)
address
- the address to inspectSimpleString getPrefix(SimpleString address)
address
- the address to inspectAddressInfo getAddressAndRoutingType(AddressInfo addressInfo)
addressInfo
- the address to inspectorg.apache.activemq.artemis.api.core.Pair
representing the canonical (i.e. non-prefixed) address
name and the org.apache.activemq.artemis.api.core.RoutingType
corresponding to the that prefix.RoutingType getRoutingTypeFromPrefix(SimpleString address, RoutingType defaultRoutingType)
Pair<SimpleString,EnumSet<RoutingType>> getAddressAndRoutingTypes(SimpleString address, EnumSet<RoutingType> defaultRoutingTypes)
address
- the address to inspectdefaultRoutingTypes
- a the java.util.Set
of org.apache.activemq.artemis.api.core.RoutingType
objects to return if no prefix match is found.org.apache.activemq.artemis.api.core.Pair
representing the canonical (i.e. non-prefixed) address
name and the java.util.Set
of org.apache.activemq.artemis.api.core.RoutingType
objects
corresponding to the that prefix.void addProducer(ServerProducer serverProducer)
void removeProducer(String ID)
Map<String,ServerProducer> getServerProducers()
String getDefaultAddress()
int getConsumerCount()
int getProducerCount()
int getDefaultConsumerWindowSize(SimpleString address)
String toManagementString()
Copyright © 2021 JBoss by Red Hat. All rights reserved.