org.apache.camel.component.sjms.consumer
Class AbstractMessageHandler

java.lang.Object
  org.apache.camel.component.sjms.consumer.AbstractMessageHandler

All Implemented Interfaces:

javax.jms.MessageListener

Direct Known Subclasses:

InOnlyMessageHandler, InOutMessageHandler

public abstract class AbstractMessageHandler
extends Object
implements javax.jms.MessageListener

Abstract MessageListener

Field Summary

protected org.slf4j.Logger

log

Constructor Summary

AbstractMessageHandler(org.apache.camel.Endpoint endpoint, ExecutorService executor)

AbstractMessageHandler(org.apache.camel.Endpoint endpoint, ExecutorService executor, org.apache.camel.spi.Synchronization synchronization)

Method Summary

abstract void	close() Method will be called to
TransactionCommitStrategy	getCommitStrategy()
org.apache.camel.Endpoint	getEndpoint()
org.apache.camel.AsyncProcessor	getProcessor()
javax.jms.Session	getSession()
abstract void	handleMessage(org.apache.camel.Exchange exchange)
boolean	isSynchronous()
boolean	isTopic()
boolean	isTransacted()
void	onMessage(javax.jms.Message message)
void	setProcessor(org.apache.camel.AsyncProcessor processor)
void	setSession(javax.jms.Session session)
void	setSynchronous(boolean async)
void	setTopic(boolean topic)
void	setTransacted(boolean transacted)

Methods inherited from class java.lang.Object

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

Field Detail

log

protected final org.slf4j.Logger log

Constructor Detail

AbstractMessageHandler

public AbstractMessageHandler(org.apache.camel.Endpoint endpoint,
                              ExecutorService executor)

AbstractMessageHandler

public AbstractMessageHandler(org.apache.camel.Endpoint endpoint,
                              ExecutorService executor,
                              org.apache.camel.spi.Synchronization synchronization)

Method Detail

onMessage

public void onMessage(javax.jms.Message message)

Specified by:

onMessage in interface javax.jms.MessageListener

handleMessage

public abstract void handleMessage(org.apache.camel.Exchange exchange)

Parameters:

exchange -

close

public abstract void close()

Method will be called to

setTransacted

public void setTransacted(boolean transacted)

isTransacted

public boolean isTransacted()

getEndpoint

public org.apache.camel.Endpoint getEndpoint()

getProcessor

public org.apache.camel.AsyncProcessor getProcessor()

setProcessor

public void setProcessor(org.apache.camel.AsyncProcessor processor)

setSession

public void setSession(javax.jms.Session session)

getSession

public javax.jms.Session getSession()

setSynchronous

public void setSynchronous(boolean async)

isSynchronous

public boolean isSynchronous()

setTopic

public void setTopic(boolean topic)

isTopic

public boolean isTopic()

getCommitStrategy

public TransactionCommitStrategy getCommitStrategy()