Package com.adaptris.core.tibrv

Class RendezvousConsumer

java.lang.Object

com.adaptris.core.AdaptrisMessageWorkerImp

com.adaptris.core.AdaptrisMessageConsumerImp

com.adaptris.core.tibrv.RendezvousConsumer

All Implemented Interfaces:

AdaptrisComponent, AdaptrisMessageConsumer, AdaptrisMessageWorker, ComponentLifecycle, ComponentLifecycleExtension, LicensedComponent, MessageEventGenerator, StateManagedComponent, com.tibco.tibrv.TibrvMsgCallback

@ComponentProfile(summary="Receive messages from Tibco Rendezvous",
                  tag="consumer,tibco",
                  recommended=com.adaptris.core.NullConnection.class)
public class RendezvousConsumer
extends AdaptrisMessageConsumerImp
implements com.tibco.tibrv.TibrvMsgCallback, LicensedComponent

Implementation of AdaptrisMessageConsumer which handles Tibco Rendezvous messages.

In the adapter configuration file this class is aliased as tibrv-rendezvous-consumer 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

Constructor Summary

Constructors

Constructor	Description
RendezvousConsumer()	Creates a new instance.

Method Summary

Modifier and Type	Method	Description
void	close()
RendezvousClient	getRendezvousClient()	Returns the RendezvousClient to use.
RendezvousTranslator	getRendezvousTranslator()	Returns the RendezvousTranslator to use.
String	getSubject()	The Subject we are consuming from.
void	init()
boolean	isEnabled(License license)
protected String	newThreadName()
void	onMsg(com.tibco.tibrv.TibrvListener listener, com.tibco.tibrv.TibrvMsg tibrvMsg)
final void	prepare()
void	setRendezvousClient(RendezvousClient r)	Sets the RendezvousClient to use.
void	setRendezvousTranslator(RendezvousTranslator r)	Sets the the RendezvousTranslator to use.
void	setSubject(String subject)	The Subject we are consuming from.
void	start()
void	stop()
protected String	subject()

Methods inherited from class com.adaptris.core.AdaptrisMessageConsumerImp

changeState, registerAdaptrisMessageListener, renameThread, requestClose, requestInit, requestStart, requestStop, retrieveAdaptrisMessageListener, retrieveComponentState

Methods inherited from class com.adaptris.core.AdaptrisMessageWorkerImp

createName, 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.AdaptrisMessageConsumer

consumeLocationKey

Methods inherited from interface com.adaptris.core.AdaptrisMessageWorker

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

Methods inherited from interface com.adaptris.core.MessageEventGenerator

createName, createQualifier, isTrackingEndpoint

Constructor Details

RendezvousConsumer

public RendezvousConsumer()

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

See Also:

• StandardRendezvousClient
• StandardRendezvousTranslator

Method Details

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()

onMsg

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

Specified by:

onMsg in interface com.tibco.tibrv.TibrvMsgCallback

See Also:

• #onMsg(com.tibco.tibrv.TibrvListener, com.tibco.tibrv.TibrvMsg)

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()

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

subject

protected String subject()

newThreadName

protected String newThreadName()

Overrides:

newThreadName in class AdaptrisMessageConsumerImp

getSubject

public String getSubject()

The Subject we are consuming from.

setSubject

public void setSubject(String subject)

The Subject we are consuming from.