org.fusesource.stompjms
Class StompJmsMessageProducer

java.lang.Object
  org.fusesource.stompjms.StompJmsMessageProducer

All Implemented Interfaces:

javax.jms.MessageProducer

Direct Known Subclasses:

StompJmsQueueSender, StompJmsTopicPublisher

public class StompJmsMessageProducer
extends java.lang.Object
implements javax.jms.MessageProducer

Implementation of a Jms MessageProducer

Field Summary

protected boolean	closed
protected int	deliveryMode
protected StompJmsDestination	destination
protected boolean	disableMessageId
protected boolean	disableTimestamp
protected boolean	flexibleDestination
protected int	priority
protected StompJmsSession	session
protected long	timeToLive

Constructor Summary

protected

StompJmsMessageProducer(StompJmsSession s, StompJmsDestination dest)

Method Summary

protected void	checkClosed()
void	close() Close the producer
int	getDeliveryMode()
javax.jms.Destination	getDestination()
boolean	getDisableMessageID()
boolean	getDisableMessageTimestamp()
int	getPriority()
long	getTimeToLive()
void	send(javax.jms.Destination destination, javax.jms.Message message)
void	send(javax.jms.Destination destination, javax.jms.Message message, int deliveryMode, int priority, long timeToLive)
void	send(javax.jms.Message message)
void	send(javax.jms.Message message, int deliveryMode, int priority, long timeToLive)
void	setDeliveryMode(int deliveryMode)
void	setDestination(javax.jms.Destination destination)
void	setDisableMessageID(boolean value)
void	setDisableMessageTimestamp(boolean value)
void	setPriority(int defaultPriority)
void	setTimeToLive(long timeToLive)

Methods inherited from class java.lang.Object

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

Field Detail

session

protected final StompJmsSession session

destination

protected StompJmsDestination destination

flexibleDestination

protected final boolean flexibleDestination

deliveryMode

protected int deliveryMode

priority

protected int priority

timeToLive

protected long timeToLive

closed

protected boolean closed

disableMessageId

protected boolean disableMessageId

disableTimestamp

protected boolean disableTimestamp

Constructor Detail

StompJmsMessageProducer

protected StompJmsMessageProducer(StompJmsSession s,
                                  StompJmsDestination dest)

Method Detail

close

public void close()

Close the producer

Specified by:

close in interface javax.jms.MessageProducer

See Also:

MessageProducer.close()

getDeliveryMode

public int getDeliveryMode()
                    throws javax.jms.JMSException

Specified by:

getDeliveryMode in interface javax.jms.MessageProducer

Returns:

the delivery mode

Throws:

javax.jms.JMSException

See Also:

MessageProducer.getDeliveryMode()

getDestination

public javax.jms.Destination getDestination()
                                     throws javax.jms.JMSException

Specified by:

getDestination in interface javax.jms.MessageProducer

Returns:

the destination

Throws:

javax.jms.JMSException

See Also:

MessageProducer.getDestination()

getDisableMessageID

public boolean getDisableMessageID()
                            throws javax.jms.JMSException

Specified by:

getDisableMessageID in interface javax.jms.MessageProducer

Returns:

true if disableIds is set

Throws:

javax.jms.JMSException

See Also:

MessageProducer.getDisableMessageID()

getDisableMessageTimestamp

public boolean getDisableMessageTimestamp()
                                   throws javax.jms.JMSException

Specified by:

getDisableMessageTimestamp in interface javax.jms.MessageProducer

Returns:

true if disable timestamp is set

Throws:

javax.jms.JMSException

See Also:

MessageProducer.getDisableMessageTimestamp()

getPriority

public int getPriority()
                throws javax.jms.JMSException

Specified by:

getPriority in interface javax.jms.MessageProducer

Returns:

the priority

Throws:

javax.jms.JMSException

See Also:

MessageProducer.getPriority()

getTimeToLive

public long getTimeToLive()
                   throws javax.jms.JMSException

Specified by:

getTimeToLive in interface javax.jms.MessageProducer

Returns:

timeToLive

Throws:

javax.jms.JMSException

See Also:

MessageProducer.getTimeToLive()

send

public void send(javax.jms.Message message)
          throws javax.jms.JMSException

Specified by:

send in interface javax.jms.MessageProducer

Parameters:

message -

Throws:

javax.jms.JMSException

See Also:

MessageProducer.send(javax.jms.Message)

send

public void send(javax.jms.Destination destination,
                 javax.jms.Message message)
          throws javax.jms.JMSException

Specified by:

send in interface javax.jms.MessageProducer

Parameters:

destination -

message -

Throws:

javax.jms.JMSException

See Also:

MessageProducer.send(javax.jms.Destination, javax.jms.Message)

send

public void send(javax.jms.Message message,
                 int deliveryMode,
                 int priority,
                 long timeToLive)
          throws javax.jms.JMSException

Specified by:

send in interface javax.jms.MessageProducer

Parameters:

message -

deliveryMode -

priority -

timeToLive -

Throws:

javax.jms.JMSException

See Also:

MessageProducer.send(javax.jms.Message, int, int, long)

send

public void send(javax.jms.Destination destination,
                 javax.jms.Message message,
                 int deliveryMode,
                 int priority,
                 long timeToLive)
          throws javax.jms.JMSException

Specified by:

send in interface javax.jms.MessageProducer

Parameters:

destination -

message -

deliveryMode -

priority -

timeToLive -

Throws:

javax.jms.JMSException

See Also:

MessageProducer.send(javax.jms.Destination, javax.jms.Message, int, int, long)

setDeliveryMode

public void setDeliveryMode(int deliveryMode)
                     throws javax.jms.JMSException

Specified by:

setDeliveryMode in interface javax.jms.MessageProducer

Parameters:

deliveryMode -

Throws:

javax.jms.JMSException

See Also:

MessageProducer.setDeliveryMode(int)

setDisableMessageID

public void setDisableMessageID(boolean value)
                         throws javax.jms.JMSException

Specified by:

setDisableMessageID in interface javax.jms.MessageProducer

Parameters:

value -

Throws:

javax.jms.JMSException

See Also:

MessageProducer.setDisableMessageID(boolean)

setDisableMessageTimestamp

public void setDisableMessageTimestamp(boolean value)
                                throws javax.jms.JMSException

Specified by:

setDisableMessageTimestamp in interface javax.jms.MessageProducer

Parameters:

value -

Throws:

javax.jms.JMSException

See Also:

MessageProducer.setDisableMessageTimestamp(boolean)

setPriority

public void setPriority(int defaultPriority)
                 throws javax.jms.JMSException

Specified by:

setPriority in interface javax.jms.MessageProducer

Parameters:

defaultPriority -

Throws:

javax.jms.JMSException

See Also:

MessageProducer.setPriority(int)

setTimeToLive

public void setTimeToLive(long timeToLive)
                   throws javax.jms.JMSException

Specified by:

setTimeToLive in interface javax.jms.MessageProducer

Parameters:

timeToLive -

Throws:

javax.jms.JMSException

See Also:

MessageProducer.setTimeToLive(long)

setDestination

public void setDestination(javax.jms.Destination destination)
                    throws javax.jms.JMSException

Parameters:

destination - the destination to set

Throws:

javax.jms.JMSException

javax.jms.InvalidDestinationException

checkClosed

protected void checkClosed()
                    throws javax.jms.IllegalStateException

Throws:

javax.jms.IllegalStateException