Modifier and Type | Method and Description |
---|---|
ClientSessionFactory |
ClientSessionFactory.addFailoverListener(FailoverEventListener listener)
Adds a FailoverEventListener to the session which is notified if a failover event occurs on the session.
|
ClientSessionFactory |
ServerLocator.createSessionFactory()
Creates a ClientSessionFactory using whatever load balancing policy is in force
|
ClientSessionFactory |
ServerLocator.createSessionFactory(String nodeID)
Creates a
ClientSessionFactory to a specific server. |
ClientSessionFactory |
ServerLocator.createSessionFactory(TransportConfiguration transportConfiguration)
Creates a
ClientSessionFactory to a specific server. |
ClientSessionFactory |
ServerLocator.createSessionFactory(TransportConfiguration transportConfiguration,
int reconnectAttempts,
boolean failoverOnInitialConnection)
Creates a
ClientSessionFactory to a specific server. |
ClientSessionFactory |
ClientSession.getSessionFactory()
Return the sessionFactory used to created this Session.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ClientSessionFactoryInternal |
Modifier and Type | Class and Description |
---|---|
class |
ClientSessionFactoryImpl |
Modifier and Type | Method and Description |
---|---|
ClientSessionFactory |
ServerLocatorImpl.createSessionFactory() |
ClientSessionFactory |
ServerLocatorImpl.createSessionFactory(String nodeID) |
ClientSessionFactory |
ServerLocatorImpl.createSessionFactory(TransportConfiguration transportConfiguration) |
ClientSessionFactory |
ServerLocatorImpl.createSessionFactory(TransportConfiguration transportConfiguration,
int reconnectAttempts,
boolean failoverOnInitialConnection) |
ClientSessionFactory |
ClientSessionImpl.getSessionFactory() |
Modifier and Type | Method and Description |
---|---|
void |
ServerLocatorImpl.factoryClosed(ClientSessionFactory factory) |
void |
ServerLocatorInternal.factoryClosed(ClientSessionFactory factory) |
Modifier and Type | Method and Description |
---|---|
ClientSessionFactory |
ActiveMQClientProtocolManager.getSessionFactory() |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQClientProtocolManager.setSessionFactory(ClientSessionFactory factory) |
Modifier and Type | Method and Description |
---|---|
ClientSessionFactory |
BridgeImpl.getSessionFactory() |
Modifier and Type | Method and Description |
---|---|
long |
ScaleDownHandler.scaleDown(ClientSessionFactory sessionFactory,
ResourceManager resourceManager,
Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap,
SimpleString managementAddress,
SimpleString targetNodeId) |
void |
ScaleDownHandler.scaleDownDuplicateIDs(Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap,
ClientSessionFactory sessionFactory,
SimpleString managementAddress,
String user,
String password) |
long |
ScaleDownHandler.scaleDownMessages(ClientSessionFactory sessionFactory,
SimpleString nodeId,
String user,
String password) |
void |
ScaleDownHandler.scaleDownTransactions(ClientSessionFactory sessionFactory,
ResourceManager resourceManager,
String user,
String password) |
Modifier and Type | Method and Description |
---|---|
ClientSessionFactory |
ActiveMQConnection.getSessionFactory() |
Constructor and Description |
---|
ActiveMQConnection(ConnectionFactoryOptions options,
String username,
String password,
int connectionType,
String clientID,
int dupsOKBatchSize,
int transactionBatchSize,
ClientSessionFactory sessionFactory) |
ActiveMQXAConnection(ConnectionFactoryOptions options,
String username,
String password,
int connectionType,
String clientID,
int dupsOKBatchSize,
int transactionBatchSize,
ClientSessionFactory sessionFactory) |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQJMSServerLogger_$logger.xaRecoverConnectionError(Exception e,
ClientSessionFactory csf) |
void |
ActiveMQJMSServerLogger.xaRecoverConnectionError(Exception e,
ClientSessionFactory csf) |
Modifier and Type | Method and Description |
---|---|
ClientSession |
ActiveMQResourceAdapter.createSession(ClientSessionFactory parameterFactory,
int ackMode,
String user,
String pass,
Boolean preAck,
Integer dupsOkBatchSize,
Integer transactionBatchSize,
boolean deliveryTransacted,
boolean useLocalTx,
Integer txTimeout) |
Modifier and Type | Method and Description |
---|---|
protected ClientSession |
ActiveMQActivation.setupSession(ClientSessionFactory cf)
Setup a session
|
Constructor and Description |
---|
ActiveMQMessageHandler(ConnectionFactoryOptions options,
ActiveMQActivation activation,
TransactionManager tm,
ClientSessionInternal session,
ClientSessionFactory cf,
int sessionNr) |
Modifier and Type | Field and Description |
---|---|
protected ClientSessionFactory |
DestinationServiceManager.consumerSessionFactory |
protected ClientSessionFactory |
QueueConsumer.factory |
protected ClientSessionFactory |
PostMessage.sessionFactory |
protected ClientSessionFactory |
ConsumersResource.sessionFactory |
protected ClientSessionFactory |
DestinationServiceManager.sessionFactory |
Modifier and Type | Method and Description |
---|---|
ClientSessionFactory |
DestinationServiceManager.getConsumerSessionFactory() |
ClientSessionFactory |
PostMessage.getSessionFactory() |
ClientSessionFactory |
ConsumersResource.getSessionFactory() |
ClientSessionFactory |
DestinationServiceManager.getSessionFactory() |
Modifier and Type | Method and Description |
---|---|
void |
DestinationServiceManager.setConsumerSessionFactory(ClientSessionFactory consumerSessionFactory) |
void |
PostMessage.setSessionFactory(ClientSessionFactory sessionFactory) |
void |
ConsumersResource.setSessionFactory(ClientSessionFactory sessionFactory) |
void |
DestinationServiceManager.setSessionFactory(ClientSessionFactory sessionFactory) |
Constructor and Description |
---|
AcknowledgedQueueConsumer(ClientSessionFactory factory,
String destination,
String id,
DestinationServiceManager serviceManager,
String selector) |
QueueConsumer(ClientSessionFactory factory,
String destination,
String id,
DestinationServiceManager serviceManager,
String selector) |
Modifier and Type | Field and Description |
---|---|
protected ClientSessionFactory |
PushConsumer.factory |
protected ClientSessionFactory |
PushConsumerResource.sessionFactory |
Modifier and Type | Method and Description |
---|---|
ClientSessionFactory |
PushConsumerResource.getSessionFactory() |
Modifier and Type | Method and Description |
---|---|
void |
PushConsumerResource.setSessionFactory(ClientSessionFactory sessionFactory) |
Constructor and Description |
---|
PushConsumer(ClientSessionFactory factory,
String destination,
String id,
PushRegistration registration,
PushStore store,
ConnectionFactoryOptions jmsOptions) |
Modifier and Type | Field and Description |
---|---|
protected ClientSessionFactory |
PushSubscriptionsResource.sessionFactory |
protected ClientSessionFactory |
SubscriptionsResource.sessionFactory |
Modifier and Type | Method and Description |
---|---|
ClientSessionFactory |
PushSubscriptionsResource.getSessionFactory() |
ClientSessionFactory |
SubscriptionsResource.getSessionFactory() |
Modifier and Type | Method and Description |
---|---|
void |
PushSubscriptionsResource.setSessionFactory(ClientSessionFactory sessionFactory) |
void |
SubscriptionsResource.setSessionFactory(ClientSessionFactory sessionFactory) |
Constructor and Description |
---|
AcknowledgedSubscriptionResource(ClientSessionFactory factory,
String destination,
String id,
DestinationServiceManager serviceManager,
String selector,
boolean durable,
Long timeout) |
PushSubscription(ClientSessionFactory factory,
String destination,
String id,
PushRegistration registration,
PushStore store,
ConnectionFactoryOptions jmsOptions) |
SubscriptionResource(ClientSessionFactory factory,
String destination,
String id,
DestinationServiceManager serviceManager,
String selector,
boolean durable,
long timeout) |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQXARecoveryLogger_$logger.xaRecoverConnectionError(Exception e,
ClientSessionFactory csf) |
void |
ActiveMQXARecoveryLogger.xaRecoverConnectionError(Exception e,
ClientSessionFactory csf) |
Modifier and Type | Method and Description |
---|---|
ClientSessionFactory |
ClientProtocolManager.getSessionFactory() |
Modifier and Type | Method and Description |
---|---|
void |
ClientProtocolManager.setSessionFactory(ClientSessionFactory factory) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.