Package com.adaptris.core.jcsmp.solace
Class SolaceJcsmpAbstractProducer
- java.lang.Object
-
- com.adaptris.core.AdaptrisMessageWorkerImp
-
- com.adaptris.core.AdaptrisMessageProducerImp
-
- com.adaptris.core.ProduceOnlyProducerImp
-
- com.adaptris.core.jcsmp.solace.SolaceJcsmpAbstractProducer
-
- All Implemented Interfaces:
AdaptrisComponent
,AdaptrisMessageProducer
,AdaptrisMessageSender
,AdaptrisMessageWorker
,ComponentLifecycle
,ComponentLifecycleExtension
,MessageEventGenerator
- Direct Known Subclasses:
SolaceJcsmpQueueProducer
,SolaceJcsmpTopicProducer
public abstract class SolaceJcsmpAbstractProducer extends ProduceOnlyProducerImp
-
-
Field Summary
-
Fields inherited from class com.adaptris.core.AdaptrisMessageWorkerImp
log
-
-
Constructor Summary
Constructors Constructor Description SolaceJcsmpAbstractProducer()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description void
doProduce(AdaptrisMessage msg, java.lang.String queueOrTopic)
protected abstract com.solacesystems.jcsmp.Destination
generateDestination(AdaptrisMessage msg, java.lang.String queueOrTopic)
SolaceJcsmpMessageTranslator
getMessageTranslator()
The message translator is responsible for translating the Solace JCSMP message object into anAdaptrisMessage
and the reverse.void
init()
void
setMessageTranslator(SolaceJcsmpMessageTranslator messageTranslator)
The message translator is responsible for translating the Solace JCSMP message object into anAdaptrisMessage
and the reverse.void
stop()
-
Methods inherited from class com.adaptris.core.ProduceOnlyProducerImp
produce, request, request
-
Methods inherited from class com.adaptris.core.AdaptrisMessageProducerImp
createName, endpoint
-
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.ComponentLifecycleExtension
prepare
-
Methods inherited from interface com.adaptris.core.MessageEventGenerator
createQualifier, isTrackingEndpoint
-
-
-
-
Method Detail
-
init
public void init() throws CoreException
- Throws:
CoreException
-
stop
public void stop()
-
doProduce
public void doProduce(AdaptrisMessage msg, java.lang.String queueOrTopic) throws ProduceException
- Specified by:
doProduce
in classProduceOnlyProducerImp
- Throws:
ProduceException
-
generateDestination
protected abstract com.solacesystems.jcsmp.Destination generateDestination(AdaptrisMessage msg, java.lang.String queueOrTopic) throws java.lang.Exception
- Throws:
java.lang.Exception
-
getMessageTranslator
public SolaceJcsmpMessageTranslator getMessageTranslator()
The message translator is responsible for translating the Solace JCSMP message object into anAdaptrisMessage
and the reverse. The translator will typically handle the payload and the headers/metadata.
-
setMessageTranslator
public void setMessageTranslator(SolaceJcsmpMessageTranslator messageTranslator)
The message translator is responsible for translating the Solace JCSMP message object into anAdaptrisMessage
and the reverse. The translator will typically handle the payload and the headers/metadata.- Parameters:
messageTranslator
-
-
-