Store non committed messages for this session
With 0.10 messages are consumed with window mode, we must send a completion
before the window size is reached so credits don't dry up.
Need this adaptor class to conform to JMS spec and throw IllegalStateException
from createDurableSubscriber, unsubscribe, createTopic & createTemporaryTopic
BlockingMethodFrameListener is a 'rendezvous' which acts as a AMQMethodListener that delegates handling of
incoming methods to a method listener implemented as a sub-class of this and hands off the processed method or
error to a consumer.
BlockingWaiter is a 'rendezvous' which delegates handling of
incoming Objects to a listener implemented as a sub-class of this and hands off the process or
error to a consumer.
Connection URL format
amqp://[user:pass@][clientid]/virtualhost?brokerlist='tcp://host:port?option=\'value\'&option=\'value\';vm://:3/virtualpath?option=\'value\''&failover='method?option=\'value\'&option='value''"
Options are of course optional except for requiring a single broker in the broker list.
DynamicSaslRegistrar provides a collection of helper methods for reading a configuration file that contains a mapping
from SASL mechanism names to implementing client factory class names and registering a security provider with the
Java runtime system, that uses the configured client factory implementations.
FailoverException is used to indicate that a synchronous request has failed to receive the reply that it is waiting
for because the fail-over process has been started whilst it was waiting for its reply.
FailoverProtectedOperation is a continuation for an operation that may throw a FailoverException because
it has been interrupted by the fail-over process.
FailoverRetrySupport is a continuation that wraps another continuation, delaying its execution until it is notified
that a blocking condition has been met, and executing the continuation within a mutex.
FailoverSupport defines an interface for different types of fail-over handlers, that provide different types of
behaviour for handling fail-overs during operations that can be interrupted by the fail-over process.
In order to protect the consistency of the connection and its child sessions, consumers and producers, the
"failover mutex" must be held when doing any operations that could be corrupted during failover.
This method is called to determine if the resource manager instance represented
by the target object is the same as the resouce manager instance represented by
the parameter xaResource.
JCAProvider is a security provider for SASL client factories that is configured from a map of SASL mechanism names
to client factories implementation class names.
Exposed JMS defined properties on converted message:
JMSDestination - we don't set here
JMSDeliveryMode - set
JMSExpiration - we don't set here
JMSPriority - we don't set here
JMSMessageID - we don't set here
JMSTimestamp - we don't set here
JMSCorrelationID - set
JMSReplyTo - set
JMSType - set
JMSRedlivered - we don't set here
Provides support for covenience interface implemented by both AMQTemporaryTopic and AMQTemporaryQueue
so that operations related to their "temporary-ness" can be abstracted out.