public class LargeMessageConsumer extends AdaptrisMessageConsumerImp implements javax.jms.MessageListener, progress.message.jclient.ChannelListener, com.adaptris.core.licensing.LicensedComponent
Implementation of AdaptrisMessageConsumer
which uses Sonic MQ Recoverable File Channels for Large Messages.
See Sonic MQ Application Programming Guide Chapter 11 for a full description of this functionality.
This should be configured with a jms-connection with the appropriate Sonic based VendorImplementation, otherwise results are undefined.
In the adapter configuration file this class is aliased as sonic-large-message-consumer which is the preferred alternative to the fully qualified classname when building your configuration.
License Required: STANDARD
log
CONFIRMATION_ID_KEY
Constructor and Description |
---|
LargeMessageConsumer() |
LargeMessageConsumer(ConsumeDestination d) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
ReceiveChannelConfig |
getConfig()
Returns the
LargeMessageConfig to use. |
java.lang.Boolean |
getDeleteWorkingFile() |
void |
init() |
boolean |
isEnabled(com.adaptris.core.licensing.License license) |
void |
onChannelStatus(progress.message.jclient.Channel channel,
java.lang.Exception e) |
void |
onMessage(javax.jms.Message jmsMsg) |
void |
prepare() |
void |
setConfig(ReceiveChannelConfig cfg)
Sets the
LargeMessageConfig to use. |
void |
setDeleteWorkingFile(java.lang.Boolean b)
Specify whether or not to delete the workfing file once processing is complete
|
void |
start() |
void |
stop() |
changeState, getDestination, registerAdaptrisMessageListener, renameThread, requestClose, requestInit, requestStart, requestStop, retrieveAdaptrisMessageListener, retrieveComponentState, setDestination
createName, createQualifier, decode, encode, getEncoder, getIsConfirmation, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isConfirmation, isTrackingEndpoint, registerConnection, registerEncoderMessageFactory, retrieveConnection, setEncoder, setIsConfirmation, setIsTrackingEndpoint, setMessageFactory, setUniqueId, withMessageFactory
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory
getUniqueId
createName, createQualifier, isConfirmation, isTrackingEndpoint
public LargeMessageConsumer()
public LargeMessageConsumer(ConsumeDestination d)
public void prepare() throws CoreException
prepare
in interface ComponentLifecycleExtension
CoreException
public boolean isEnabled(com.adaptris.core.licensing.License license)
isEnabled
in interface com.adaptris.core.licensing.LicensedComponent
public void init() throws CoreException
init
in interface ComponentLifecycle
CoreException
ComponentLifecycle.init()
public void start() throws CoreException
start
in interface ComponentLifecycle
CoreException
ComponentLifecycle.start()
public void onMessage(javax.jms.Message jmsMsg)
onMessage
in interface javax.jms.MessageListener
MessageListener.onMessage(javax.jms.Message)
public void onChannelStatus(progress.message.jclient.Channel channel, java.lang.Exception e)
onChannelStatus
in interface progress.message.jclient.ChannelListener
public void stop()
stop
in interface ComponentLifecycle
ComponentLifecycle.stop()
public void close()
close
in interface ComponentLifecycle
ComponentLifecycle.close()
public ReceiveChannelConfig getConfig()
Returns the LargeMessageConfig
to use.
LargeMessageConfig
to usepublic void setConfig(ReceiveChannelConfig cfg)
Sets the LargeMessageConfig
to use. May not be null.
cfg
- the LargeMessageConfig
to usepublic java.lang.Boolean getDeleteWorkingFile()
public void setDeleteWorkingFile(java.lang.Boolean b)
b
- the deleteWorkingFile to set, defaults to false.Copyright Adaptris