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

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 Queue
void	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

Constructor Detail

SolaceJcsmpQueueProducer

public SolaceJcsmpQueueProducer()

Method Detail

prepare

public void prepare()
             throws CoreException

Throws:

CoreException

endpoint

public java.lang.String endpoint(AdaptrisMessage msg)
                          throws ProduceException

Specified by:

endpoint in class AdaptrisMessageProducerImp

Throws:

ProduceException

generateDestination

protected com.solacesystems.jcsmp.Destination generateDestination(AdaptrisMessage msg,
                                                                  java.lang.String queueName)
                                                           throws java.lang.Exception

Specified by:

generateDestination in class SolaceJcsmpAbstractProducer

Throws:

java.lang.Exception

getQueue

public java.lang.String getQueue()

The Solace Queue

setQueue

public void setQueue(java.lang.String queue)

The Solace Queue