Modifier and Type | Method and Description |
---|---|
ServerLocator |
ServerLocator.addIncomingInterceptor(Interceptor interceptor)
Adds an interceptor which will be executed after packets are received from the server.
|
ServerLocator |
ServerLocator.addOutgoingInterceptor(Interceptor interceptor)
Adds an interceptor which will be executed before packets are sent to the server.
|
boolean |
ServerLocator.removeIncomingInterceptor(Interceptor interceptor)
Removes an incoming interceptor.
|
boolean |
ServerLocator.removeOutgoingInterceptor(Interceptor interceptor)
Removes an outgoing interceptor.
|
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQClientLogger.errorCallingInterceptor(Throwable e,
Interceptor interceptor) |
Modifier and Type | Method and Description |
---|---|
ServerLocatorImpl |
ServerLocatorImpl.addIncomingInterceptor(Interceptor interceptor) |
ServerLocatorImpl |
ServerLocatorImpl.addOutgoingInterceptor(Interceptor interceptor) |
boolean |
ServerLocatorImpl.removeIncomingInterceptor(Interceptor interceptor) |
boolean |
ServerLocatorImpl.removeOutgoingInterceptor(Interceptor interceptor) |
Constructor and Description |
---|
ClientSessionFactoryImpl(ServerLocatorInternal serverLocator,
TransportConfiguration connectorConfig,
long callTimeout,
long callFailoverTimeout,
long clientFailureCheckPeriod,
long connectionTTL,
long retryInterval,
double retryIntervalMultiplier,
long maxRetryInterval,
int reconnectAttempts,
Executor threadPool,
ScheduledExecutorService scheduledThreadPool,
List<Interceptor> incomingInterceptors,
List<Interceptor> outgoingInterceptors) |
ClientSessionFactoryImpl(ServerLocatorInternal serverLocator,
TransportConfiguration connectorConfig,
long callTimeout,
long callFailoverTimeout,
long clientFailureCheckPeriod,
long connectionTTL,
long retryInterval,
double retryIntervalMultiplier,
long maxRetryInterval,
int reconnectAttempts,
Executor threadPool,
ScheduledExecutorService scheduledThreadPool,
List<Interceptor> incomingInterceptors,
List<Interceptor> outgoingInterceptors) |
Modifier and Type | Method and Description |
---|---|
List<Interceptor> |
CoreProtocolManagerFactory.filterInterceptors(List<BaseInterceptor> interceptors) |
ProtocolManagerFactory<Interceptor> |
CoreProtocolManager.getFactory() |
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
ActiveMQClientProtocolManager.connect(Connection transportConnection,
long callTimeout,
long callFailoverTimeout,
List<Interceptor> incomingInterceptors,
List<Interceptor> outgoingInterceptors,
TopologyResponseHandler topologyResponseHandler) |
RemotingConnection |
ActiveMQClientProtocolManager.connect(Connection transportConnection,
long callTimeout,
long callFailoverTimeout,
List<Interceptor> incomingInterceptors,
List<Interceptor> outgoingInterceptors,
TopologyResponseHandler topologyResponseHandler) |
static String |
ChannelImpl.invokeInterceptors(Packet packet,
List<Interceptor> interceptors,
RemotingConnection connection) |
Constructor and Description |
---|
ChannelImpl(CoreRemotingConnection connection,
long id,
int confWindowSize,
List<Interceptor> interceptors) |
CoreProtocolManager(CoreProtocolManagerFactory factory,
ActiveMQServer server,
List<Interceptor> incomingInterceptors,
List<Interceptor> outgoingInterceptors) |
CoreProtocolManager(CoreProtocolManagerFactory factory,
ActiveMQServer server,
List<Interceptor> incomingInterceptors,
List<Interceptor> outgoingInterceptors) |
RemotingConnectionImpl(PacketDecoder packetDecoder,
Connection transportConnection,
long blockingCallTimeout,
long blockingCallFailoverTimeout,
List<Interceptor> incomingInterceptors,
List<Interceptor> outgoingInterceptors) |
RemotingConnectionImpl(PacketDecoder packetDecoder,
Connection transportConnection,
long blockingCallTimeout,
long blockingCallFailoverTimeout,
List<Interceptor> incomingInterceptors,
List<Interceptor> outgoingInterceptors) |
Modifier and Type | Class and Description |
---|---|
class |
HQPropertiesConversionInterceptor |
Modifier and Type | Class and Description |
---|---|
static class |
ClusterManager.IncomingInterceptorLookingForExceptionMessage |
Modifier and Type | Method and Description |
---|---|
void |
ClusterController.addIncomingInterceptorForReplication(Interceptor interceptor)
add an interceptor
|
Modifier and Type | Method and Description |
---|---|
RemotingConnection |
ClientProtocolManager.connect(Connection transportConnection,
long callTimeout,
long callFailoverTimeout,
List<Interceptor> incomingInterceptors,
List<Interceptor> outgoingInterceptors,
TopologyResponseHandler topologyResponseHandler) |
RemotingConnection |
ClientProtocolManager.connect(Connection transportConnection,
long callTimeout,
long callFailoverTimeout,
List<Interceptor> incomingInterceptors,
List<Interceptor> outgoingInterceptors,
TopologyResponseHandler topologyResponseHandler) |
Copyright © 2018 JBoss by Red Hat. All rights reserved.