public interface VendorImplementationBase extends ComponentLifecycleExtension, ConnectionComparator<VendorImplementationBase>
Modifier and Type | Method and Description |
---|---|
javax.jms.MessageConsumer |
createConsumer(JmsDestination dest,
java.lang.String msgSelector,
JmsActorConfig c)
Create a message consumer for the given destination and filter expression.
|
JmsDestination |
createDestination(java.lang.String destination,
JmsActorConfig c)
Create either a
Topic or Queue based on a RFC6167 style destination. |
javax.jms.Queue |
createQueue(java.lang.String name,
JmsActorConfig c)
Create or otherwise obtain a
Queue . |
default javax.jms.MessageConsumer |
createQueueReceiver(ConsumeDestination dest,
JmsActorConfig c)
Deprecated.
since 3.11.0 since
ConsumeDestination is considered deprecated. |
javax.jms.MessageConsumer |
createQueueReceiver(java.lang.String queue,
java.lang.String filter,
JmsActorConfig c)
Create or otherwise get a MessageConsumer
|
javax.jms.Session |
createSession(javax.jms.Connection c,
boolean transacted,
int acknowledgeMode)
Create or otherwise get a Session
|
javax.jms.Topic |
createTopic(java.lang.String name,
JmsActorConfig c)
Create or otherwise obtain a
Topic . |
default javax.jms.MessageConsumer |
createTopicSubscriber(ConsumeDestination dest,
java.lang.String subscriptionId,
JmsActorConfig c)
Deprecated.
since 3.11.0 since
ConsumeDestination is considered deprecated. |
javax.jms.MessageConsumer |
createTopicSubscriber(java.lang.String topic,
java.lang.String filter,
java.lang.String subscriptionID,
JmsActorConfig c)
Create or otherwise get a TopicSubscriber.
|
java.lang.String |
retrieveBrokerDetailsForLogging()
Returns the broker details used to create the underlying
ConnectionFactory . |
prepare
connectionEquals
java.lang.String retrieveBrokerDetailsForLogging()
Returns the broker details used to create the underlying ConnectionFactory
. This is delegated to the
VendorImplementation
because it may over-ride the broker details configured in JmsConnection
.
ConnectionFactory
javax.jms.Queue createQueue(java.lang.String name, JmsActorConfig c) throws javax.jms.JMSException
Create or otherwise obtain a Queue
.
name
- the name of the queuec
- the ConfigurationQueue
objectjavax.jms.JMSException
- if any occurjavax.jms.Topic createTopic(java.lang.String name, JmsActorConfig c) throws javax.jms.JMSException
Create or otherwise obtain a Topic
.
name
- the name of the topicc
- the ConfigurationTopic
objectjavax.jms.JMSException
- if any occurJmsDestination createDestination(java.lang.String destination, JmsActorConfig c) throws javax.jms.JMSException
Topic
or Queue
based on a RFC6167 style destination.
While RFC6167 defines the ability to use jndi to lookup the (as part of the 'jndi' variant section); this is not supported. The standard deliveryMode, timeToLive, priority, replyToName properties are supported. If not specified, then they will be inherited from the producers configuration. For instance you could have the following destinations:
In addition to the standard deliveryMode, timeToLive, priority, replyToName, there are also some custom parameters when dealing with topics.
subscriptionId
- which indicates the subscriptionId that should be used when
attaching a subscriber to a topic; jms:topic:MyTopicName?subscriptionId=myId
would
return a JmsDestination.subscriptionId()
of myId
noLocal
- which corresponds to the
Session.createConsumer(javax.jms.Destination, String, boolean)
noLocal
setting. This defaults to false, if not specified.destination
- a RFC6167 style destination.c
- configurationJmsDestination
.javax.jms.JMSException
- wrapping other exceptions.javax.jms.MessageConsumer createConsumer(JmsDestination dest, java.lang.String msgSelector, JmsActorConfig c) throws javax.jms.JMSException
If the JmsDestination.destinationType()
is a
JmsDestination.DestinationType.TOPIC
, and JmsDestination.subscriptionId()
is
not blank, then a durable subscriber is created otherwise a standard consumer is created. Also
JmsDestination.noLocal()
is passed through to the appropriate Session
methods.
dest
- the destinationmsgSelector
- the message selectorc
- configurationMessageConsumer
javax.jms.JMSException
- wrapping other exceptions.@Deprecated @Removal(version="4.0.0") default javax.jms.MessageConsumer createQueueReceiver(ConsumeDestination dest, JmsActorConfig c) throws javax.jms.JMSException
ConsumeDestination
is considered deprecated.dest
- the destinationc
- the configuration.javax.jms.JMSException
createQueueReceiver(String, String, JmsActorConfig)
with the destination and
filter expression from the destination.javax.jms.MessageConsumer createQueueReceiver(java.lang.String queue, java.lang.String filter, JmsActorConfig c) throws javax.jms.JMSException
queue
- the Queuefilter
- the filter expression if anyc
- the configuration.javax.jms.JMSException
@Deprecated @Removal(version="4.0.0") default javax.jms.MessageConsumer createTopicSubscriber(ConsumeDestination dest, java.lang.String subscriptionId, JmsActorConfig c) throws javax.jms.JMSException
ConsumeDestination
is considered deprecated.dest
- the destinationc
- the configuration.javax.jms.JMSException
createTopicSubscriber(String, String, String, JmsActorConfig)
with the
destination and filter expression from the destination.javax.jms.MessageConsumer createTopicSubscriber(java.lang.String topic, java.lang.String filter, java.lang.String subscriptionID, JmsActorConfig c) throws javax.jms.JMSException
topic
- the topicfilter
- the filter expression if anysubscriptionID
- the subscriptionID for durable subscribersc
- the configurationjavax.jms.JMSException
javax.jms.Session createSession(javax.jms.Connection c, boolean transacted, int acknowledgeMode) throws javax.jms.JMSException
c
- the Connectiontransacted
- whether or not the session is transactedjavax.jms.JMSException
- if there were any JMS related exceptions