Modifier and Type | Method and Description |
---|---|
void |
ActiveMQServerControlImpl.buildSessionJSON(JsonArrayBuilder array,
ServerSession sess) |
Modifier and Type | Method and Description |
---|---|
Object |
SessionView.getField(ServerSession session,
String fieldName) |
JsonObjectBuilder |
SessionView.toJson(ServerSession session) |
Modifier and Type | Method and Description |
---|---|
boolean |
SessionFilterPredicate.test(ServerSession session) |
Modifier and Type | Method and Description |
---|---|
ServerSession |
ServerSessionPacketHandler.getSession() |
Constructor and Description |
---|
ServerSessionPacketHandler(ActiveMQServer server,
CoreProtocolManager manager,
ServerSession session,
StorageManager storageManager,
Channel channel) |
Modifier and Type | Method and Description |
---|---|
ServerSession |
ActiveMQServer.createSession(String name,
String username,
String password,
int minLargeMessageSize,
RemotingConnection remotingConnection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
boolean autoCreateQueues,
OperationContext context,
Map<SimpleString,RoutingType> prefixes) |
ServerSession |
ActiveMQServer.getSessionByID(String sessionID) |
ServerSession |
ActiveMQServer.lookupSession(String metakey,
String metavalue) |
Modifier and Type | Method and Description |
---|---|
Set<ServerSession> |
ActiveMQServer.getSessions() |
List<ServerSession> |
ActiveMQServer.getSessions(String connectionID) |
Modifier and Type | Class and Description |
---|---|
class |
ServerSessionImpl
Server side Session implementation
|
Modifier and Type | Method and Description |
---|---|
ServerSession |
ActiveMQServerImpl.createSession(String name,
String username,
String password,
int minLargeMessageSize,
RemotingConnection connection,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
boolean xa,
String defaultAddress,
SessionCallback callback,
boolean autoCreateQueues,
OperationContext context,
Map<SimpleString,RoutingType> prefixes) |
ServerSession |
ActiveMQServerImpl.getSessionByID(String sessionName) |
ServerSession |
ActiveMQServerImpl.lookupSession(String key,
String value) |
Modifier and Type | Method and Description |
---|---|
Set<ServerSession> |
ActiveMQServerImpl.getSessions() |
List<ServerSession> |
ActiveMQServerImpl.getSessions(String connectionID) |
Constructor and Description |
---|
ServerConsumerImpl(long id,
ServerSession session,
QueueBinding binding,
Filter filter,
boolean started,
boolean browseOnly,
StorageManager storageManager,
SessionCallback callback,
boolean preAcknowledge,
boolean strictUpdateDeliveryCount,
ManagementService managementService,
ActiveMQServer server) |
ServerConsumerImpl(long id,
ServerSession session,
QueueBinding binding,
Filter filter,
boolean started,
boolean browseOnly,
StorageManager storageManager,
SessionCallback callback,
boolean preAcknowledge,
boolean strictUpdateDeliveryCount,
ManagementService managementService,
boolean supportLargeMessage,
Integer credits,
ActiveMQServer server) |
ServerConsumerImpl(long id,
ServerSession session,
QueueBinding binding,
Filter filter,
int priority,
boolean started,
boolean browseOnly,
StorageManager storageManager,
SessionCallback callback,
boolean preAcknowledge,
boolean strictUpdateDeliveryCount,
ManagementService managementService,
boolean supportLargeMessage,
Integer credits,
ActiveMQServer server) |
Modifier and Type | Method and Description |
---|---|
default void |
ActiveMQServerSessionPlugin.afterCloseSession(ServerSession session,
boolean failed)
After a session is closed
|
default void |
ActiveMQServerSessionPlugin.afterCreateSession(ServerSession session)
After a session has been created.
|
default void |
ActiveMQServerMessagePlugin.afterSend(ServerSession session,
Transaction tx,
Message message,
boolean direct,
boolean noAutoCreateQueue,
RoutingStatus result)
After a message is sent
|
default void |
ActiveMQServerSessionPlugin.afterSessionMetadataAdded(ServerSession session,
String key,
String data)
After session metadata is added to the session
|
default void |
ActiveMQServerSessionPlugin.beforeCloseSession(ServerSession session,
boolean failed)
Before a session is closed
|
default void |
ActiveMQServerMessagePlugin.beforeSend(ServerSession session,
Transaction tx,
Message message,
boolean direct,
boolean noAutoCreateQueue)
Before a message is sent
|
default void |
ActiveMQServerSessionPlugin.beforeSessionMetadataAdded(ServerSession session,
String key,
String data)
Before session metadata is added to the session
|
default void |
ActiveMQServerSessionPlugin.duplicateSessionMetadataFailure(ServerSession session,
String key,
String data)
Called when adding session metadata fails because the metadata is a duplicate
|
default void |
ActiveMQServerMessagePlugin.onSendException(ServerSession session,
Transaction tx,
Message message,
boolean direct,
boolean noAutoCreateQueue,
Exception e)
When there was an exception sending the message
|
Modifier and Type | Method and Description |
---|---|
void |
LoggingActiveMQServerPlugin.afterCloseSession(ServerSession session,
boolean failed)
After a session is closed
|
void |
LoggingActiveMQServerPlugin.afterCreateSession(ServerSession session)
After a session has been created.
|
void |
LoggingActiveMQServerPlugin.afterSend(ServerSession session,
Transaction tx,
Message message,
boolean direct,
boolean noAutoCreateQueue,
RoutingStatus result)
After a message is sent
|
void |
LoggingActiveMQServerPluginLogger.afterSendDetails(String messageID,
Message message,
String sessionName,
Transaction tx,
ServerSession session,
boolean direct,
boolean noAutoCreateQueue) |
void |
LoggingActiveMQServerPlugin.afterSessionMetadataAdded(ServerSession session,
String key,
String data)
After session metadata is added to the session
|
void |
LoggingActiveMQServerPluginLogger.afterSessionMetadataAddedDetails(String sessionName,
ServerSession session,
String key,
String data) |
void |
LoggingActiveMQServerPlugin.beforeCloseSession(ServerSession session,
boolean failed)
Before a session is closed
|
void |
LoggingActiveMQServerPluginLogger.beforeCloseSession(String sessionName,
ServerSession session,
boolean failed) |
void |
LoggingActiveMQServerPluginLogger.beforeSend(Message message,
Transaction tx,
ServerSession session,
boolean direct,
boolean noAutoCreateQueue) |
void |
LoggingActiveMQServerPlugin.beforeSend(ServerSession session,
Transaction tx,
Message message,
boolean direct,
boolean noAutoCreateQueue)
Before a message is sent
|
void |
LoggingActiveMQServerPlugin.beforeSessionMetadataAdded(ServerSession session,
String key,
String data)
Before session metadata is added to the session
|
void |
LoggingActiveMQServerPluginLogger.beforeSessionMetadataAdded(String sessionName,
ServerSession session,
String key,
String data) |
void |
LoggingActiveMQServerPluginLogger.onSendErrorDetails(String messageID,
Message message,
String sessionName,
Transaction tx,
ServerSession session,
boolean direct,
boolean noAutoCreateQueue) |
void |
LoggingActiveMQServerPlugin.onSendException(ServerSession session,
Transaction tx,
Message message,
boolean direct,
boolean noAutoCreateQueue,
Exception e) |
Copyright © 2019 JBoss by Red Hat. All rights reserved.