Package org.apache.ofbiz.service.jms

Class AbstractJmsListener

java.lang.Object

org.apache.ofbiz.service.jms.AbstractJmsListener

All Implemented Interfaces:

javax.jms.ExceptionListener, javax.jms.MessageListener, GenericMessageListener

Direct Known Subclasses:

JmsQueueListener, JmsTopicListener

public abstract class AbstractJmsListener
extends Object
implements GenericMessageListener, javax.jms.ExceptionListener

AbstractJmsListener

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractJmsListener(Delegator delegator)	Initializes the LocalDispatcher for this service listener.

Method Summary

Modifier and Type	Method	Description
boolean	isConnected()	Indicator if a connection is present.
void	onException(javax.jms.JMSException je)	On exception try to re-establish connection to the JMS server.
void	onMessage(javax.jms.Message message)	Receives the MapMessage and processes the service.
void	refresh()	Refresh the connection.
protected Map<String,Object>	runService(javax.jms.MapMessage message)	Runs the service defined in the MapMessage
protected void	setConnected(boolean connected)	Setter method for the connected field.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ofbiz.service.jms.GenericMessageListener

close, load

Constructor Details

AbstractJmsListener

protected AbstractJmsListener(Delegator delegator)

Initializes the LocalDispatcher for this service listener.

Parameters:

delegator - the delegator associated to the dispatcher

Method Details

runService

protected Map<String,Object> runService(javax.jms.MapMessage message)

Runs the service defined in the MapMessage

Parameters:

message -

Returns:

Map

onMessage

public void onMessage(javax.jms.Message message)

Receives the MapMessage and processes the service.

Specified by:

onMessage in interface javax.jms.MessageListener

See Also:

• MessageListener.onMessage(Message)

onException

public void onException(javax.jms.JMSException je)

On exception try to re-establish connection to the JMS server.

Specified by:

onException in interface javax.jms.ExceptionListener

See Also:

• ExceptionListener.onException(JMSException)

refresh

public void refresh()
             throws GenericServiceException

Description copied from interface: GenericMessageListener

Refresh the connection.

Specified by:

refresh in interface GenericMessageListener

Throws:

GenericServiceException

isConnected

public boolean isConnected()

Description copied from interface: GenericMessageListener

Indicator if a connection is present.

Specified by:

isConnected in interface GenericMessageListener

Returns:

true if connectio is present.

setConnected

protected void setConnected(boolean connected)

Setter method for the connected field.

Parameters:

connected -