com.adaptris.core.tibrv

Class RendezvousProducer

java.lang.Object

com.adaptris.core.AdaptrisMessageWorkerImp

com.adaptris.core.AdaptrisMessageProducerImp

com.adaptris.core.ProduceOnlyProducerImp

com.adaptris.core.tibrv.RendezvousProducer

All Implemented Interfaces:

AdaptrisComponent, AdaptrisMessageProducer, AdaptrisMessageSender, AdaptrisMessageWorker, ComponentLifecycle, ComponentLifecycleExtension, LicensedComponent, MessageEventGenerator, com.tibco.tibrv.TibrvMsgCallback

@ComponentProfile(summary="Send messages to Tibco Rendezvous",
                  tag="producer,tibco",
                  recommended=com.adaptris.core.NullConnection.class)
public class RendezvousProducer
extends ProduceOnlyProducerImp
implements com.tibco.tibrv.TibrvMsgCallback, LicensedComponent

Implementation of AdaptrisMessageProducee which handles Tibco Rendezvous messages.

Implements TibrvMsgCallback to handle confirmation messages which are received if this class is used in conjunction with CertifiedRendezvousClient.

In the adapter configuration file this class is aliased as tibrv-rendezvous-producer which is the preferred alternative to the fully qualified classname when building your configuration.

License Required: ENTERPRISE

Field Summary

Fields inherited from class com.adaptris.core.AdaptrisMessageWorkerImp

log

Fields inherited from interface com.adaptris.core.MessageEventGenerator

CONFIRMATION_ID_KEY

Constructor Summary

Constructors

Constructor and Description
RendezvousProducer() Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	close()
RendezvousClient	getRendezvousClient() Returns the RendezvousClient to use.
RendezvousTranslator	getRendezvousTranslator() Returns the RendezvousTranslator to use.
void	init()
boolean	isEnabled(License license)
void	onMsg(com.tibco.tibrv.TibrvListener listner, com.tibco.tibrv.TibrvMsg tibrvMsg)
void	prepare()
void	produce(AdaptrisMessage msg, ProduceDestination destination)
void	setRendezvousClient(RendezvousClient r) Sets the RendezvousClient to use.
void	setRendezvousTranslator(RendezvousTranslator r) Sets the the RendezvousTranslator to use.
void	start()
void	stop()
java.lang.String	toString()

Methods inherited from class com.adaptris.core.ProduceOnlyProducerImp

produce, request, request, request, request

Methods inherited from class com.adaptris.core.AdaptrisMessageProducerImp

getDestination, setDestination

Methods inherited from class com.adaptris.core.AdaptrisMessageWorkerImp

createName, createQualifier, decode, encode, getEncoder, getIsConfirmation, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isConfirmation, isTrackingEndpoint, registerConnection, registerEncoderMessageFactory, retrieveConnection, setEncoder, setIsConfirmation, setIsTrackingEndpoint, setMessageFactory, setUniqueId, withMessageFactory

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.adaptris.core.AdaptrisMessageWorker

decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory

Methods inherited from interface com.adaptris.core.AdaptrisComponent

getUniqueId

Methods inherited from interface com.adaptris.core.MessageEventGenerator

createName, createQualifier, isConfirmation, isTrackingEndpoint

Constructor Detail

RendezvousProducer

public RendezvousProducer()

Creates a new instance. Defaults to new StandardRendezvousClient and StandardRendezvousTranslator.

See Also:

StandardRendezvousClient, StandardRendezvousTranslator

Method Detail

prepare

public final void prepare()
                   throws CoreException

Specified by:

prepare in interface ComponentLifecycleExtension

Throws:

CoreException

isEnabled

public boolean isEnabled(License license)

Specified by:

isEnabled in interface LicensedComponent

init

public void init()
          throws CoreException

Specified by:

init in interface ComponentLifecycle

Throws:

CoreException

See Also:

ComponentLifecycle.init()

start

public void start()
           throws CoreException

Specified by:

start in interface ComponentLifecycle

Throws:

CoreException

See Also:

ComponentLifecycle.start()

stop

public void stop()

Specified by:

stop in interface ComponentLifecycle

See Also:

ComponentLifecycle.stop()

close

public void close()

Specified by:

close in interface ComponentLifecycle

See Also:

ComponentLifecycle.close()

onMsg

public void onMsg(com.tibco.tibrv.TibrvListener listner,
                  com.tibco.tibrv.TibrvMsg tibrvMsg)

Specified by:

onMsg in interface com.tibco.tibrv.TibrvMsgCallback

See Also:

(com.tibco.tibrv.TibrvListener, com.tibco.tibrv.TibrvMsg)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

See Also:

Object.toString()

produce

public void produce(AdaptrisMessage msg,
                    ProduceDestination destination)
             throws ProduceException

Specified by:

produce in interface AdaptrisMessageSender

Throws:

ProduceException

See Also:

#produce(com.adaptris.core.AdaptrisMessage, com.adaptris.core.ProduceDestination)

getRendezvousTranslator

public RendezvousTranslator getRendezvousTranslator()

Returns the RendezvousTranslator to use.

Returns:

the RendezvousTranslator to use

setRendezvousTranslator

public void setRendezvousTranslator(RendezvousTranslator r)

Sets the the RendezvousTranslator to use.

Parameters:

r - the RendezvousTranslator to use

getRendezvousClient

public RendezvousClient getRendezvousClient()

Returns the RendezvousClient to use.

Returns:

the RendezvousClient to use

setRendezvousClient

public void setRendezvousClient(RendezvousClient r)

Sets the RendezvousClient to use.

Parameters:

r - the RendezvousClient to use