Package org.objectweb.joram.mom.dest.jms

Class JMSDistribution

java.lang.Object

org.objectweb.joram.mom.dest.jms.JMSDistribution

All Implemented Interfaces:

DistributionHandler

public class JMSDistribution
extends Object
implements DistributionHandler

Distribution handler for the JMS distribution bridge.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	JMSDistribution.SessionAndProducer

Field Summary

Fields

Modifier and Type	Field	Description
private List<String>	connectionNames
private static boolean	DEBUG
private static String	DESTINATION_NAME_PROP
private String	destName	Destination JNDI name.
private long	lastUpdate
(package private) long	lastwarn
private static Logger	logger
private static String	ROUTING_PROP
private LinkedHashMap<String,JMSDistribution.SessionAndProducer>	sessions
private static String	UPDATE_PERIOD_PROP
private long	updatePeriod

Constructor Summary

Constructors

Constructor	Description
JMSDistribution()

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the JMS distribution module and all associated resources.
void	distribute(Message message)	Distributes the given message outside of the JORAM server.
void	init(Properties properties, boolean firstTime)	Configures the handler with the given properties.

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final Logger logger

DEBUG

private static final boolean DEBUG

DESTINATION_NAME_PROP

private static final String DESTINATION_NAME_PROP

See Also:

Constant Field Values

UPDATE_PERIOD_PROP

private static final String UPDATE_PERIOD_PROP

See Also:

Constant Field Values

ROUTING_PROP

private static final String ROUTING_PROP

See Also:

Constant Field Values

sessions

private LinkedHashMap<String,JMSDistribution.SessionAndProducer> sessions

connectionNames

private List<String> connectionNames

destName

private String destName

Destination JNDI name.

lastUpdate

private long lastUpdate

updatePeriod

private long updatePeriod

lastwarn

long lastwarn

Constructor Detail

JMSDistribution

public JMSDistribution()

Method Detail

init

public void init(Properties properties,
                 boolean firstTime)

Description copied from interface: DistributionHandler

Configures the handler with the given properties.

Specified by:

init in interface DistributionHandler

Parameters:

properties - The initial set of properties.

distribute

public void distribute(Message message)
                throws Exception

Description copied from interface: DistributionHandler

Distributes the given message outside of the JORAM server.

Specified by:

distribute in interface DistributionHandler

Parameters:

message - the message to distribute

Throws:

Exception - if the message could not be distributed. The message will be forwarded to a DMQ, if any.

close

public void close()

Closes the JMS distribution module and all associated resources. Called by generic behavior during the destination finalization.

Specified by:

close in interface DistributionHandler