Package com.adaptris.core.jcsmp.solace
Class SolaceJcsmpQueueProducer
- java.lang.Object
-
- com.adaptris.core.AdaptrisMessageWorkerImp
-
- com.adaptris.core.AdaptrisMessageProducerImp
-
- com.adaptris.core.ProduceOnlyProducerImp
-
- com.adaptris.core.jcsmp.solace.SolaceJcsmpAbstractProducer
-
- com.adaptris.core.jcsmp.solace.SolaceJcsmpQueueProducer
-
- All Implemented Interfaces:
AdaptrisComponent
,AdaptrisMessageProducer
,AdaptrisMessageSender
,AdaptrisMessageWorker
,ComponentLifecycle
,ComponentLifecycleExtension
,MessageEventGenerator
@ComponentProfile(summary="A Solace native JCSMP component will produce your messages to the Solace VPN queue.", tag="queue,producer,solace,jcsmp", since="3.9.3") public class SolaceJcsmpQueueProducer extends SolaceJcsmpAbstractProducer
This implementation of
AdaptrisMessageProducer
will use the Solace Jcsmp Api to produce messages to a queue on your Solace router.In the adapter configuration file this class is aliased as solace-jcsmp-queue-producer which is the preferred alternative to the fully qualified classname when building your configuration.
-
-
Field Summary
-
Fields inherited from class com.adaptris.core.AdaptrisMessageWorkerImp
log
-
-
Constructor Summary
Constructors Constructor Description SolaceJcsmpQueueProducer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.String
endpoint(AdaptrisMessage msg)
protected com.solacesystems.jcsmp.Destination
generateDestination(AdaptrisMessage msg, java.lang.String queueName)
java.lang.String
getQueue()
The Solace Queuevoid
prepare()
void
setQueue(java.lang.String queue)
The Solace Queue-
Methods inherited from class com.adaptris.core.jcsmp.solace.SolaceJcsmpAbstractProducer
doProduce, getMessageTranslator, init, setMessageTranslator, stop
-
Methods inherited from class com.adaptris.core.ProduceOnlyProducerImp
produce, request, request
-
Methods inherited from class com.adaptris.core.AdaptrisMessageProducerImp
createName
-
Methods inherited from class com.adaptris.core.AdaptrisMessageWorkerImp
createQualifier, decode, encode, getEncoder, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isTrackingEndpoint, registerConnection, registerEncoderMessageFactory, retrieveConnection, setEncoder, setIsTrackingEndpoint, setMessageFactory, setUniqueId, withMessageFactory, withUniqueID
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface com.adaptris.core.AdaptrisComponent
getUniqueId
-
Methods inherited from interface com.adaptris.core.AdaptrisMessageWorker
decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory
-
Methods inherited from interface com.adaptris.core.ComponentLifecycle
close, start
-
Methods inherited from interface com.adaptris.core.MessageEventGenerator
createQualifier, isTrackingEndpoint
-
-
-
-
Method Detail
-
prepare
public void prepare() throws CoreException
- Throws:
CoreException
-
endpoint
public java.lang.String endpoint(AdaptrisMessage msg) throws ProduceException
- Specified by:
endpoint
in classAdaptrisMessageProducerImp
- Throws:
ProduceException
-
generateDestination
protected com.solacesystems.jcsmp.Destination generateDestination(AdaptrisMessage msg, java.lang.String queueName) throws java.lang.Exception
- Specified by:
generateDestination
in classSolaceJcsmpAbstractProducer
- Throws:
java.lang.Exception
-
getQueue
public java.lang.String getQueue()
The Solace Queue
-
setQueue
public void setQueue(java.lang.String queue)
The Solace Queue
-
-