org.fusesource.stompjms
Class StompJmsQueueSender

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

All Implemented Interfaces:

javax.jms.MessageProducer, javax.jms.QueueSender

public class StompJmsQueueSender
extends StompJmsMessageProducer
implements javax.jms.QueueSender

Implementation of a Queue Sender

Field Summary

Fields inherited from class org.fusesource.stompjms.StompJmsMessageProducer

closed, deliveryMode, destination, disableMessageId, disableTimestamp, flexibleDestination, priority, session, timeToLive

Constructor Summary

protected

StompJmsQueueSender(StompJmsSession s, StompJmsDestination dest) Constructor

Method Summary

javax.jms.Queue	getQueue()
void	send(javax.jms.Queue queue, javax.jms.Message message)
void	send(javax.jms.Queue queue, javax.jms.Message message, int deliveryMode, int priority, long timeToLive)

Methods inherited from class org.fusesource.stompjms.StompJmsMessageProducer

checkClosed, close, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getPriority, getTimeToLive, send, send, send, send, setDeliveryMode, setDestination, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.jms.QueueSender

send, send

Methods inherited from interface javax.jms.MessageProducer

close, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getPriority, getTimeToLive, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive

Constructor Detail

StompJmsQueueSender

protected StompJmsQueueSender(StompJmsSession s,
                              StompJmsDestination dest)

Constructor

Parameters:

s -

dest -

Method Detail

getQueue

public javax.jms.Queue getQueue()
                         throws javax.jms.IllegalStateException

Specified by:

getQueue in interface javax.jms.QueueSender

Returns:

the Queue

Throws:

javax.jms.IllegalStateException

See Also:

QueueSender.getQueue()

send

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

Specified by:

send in interface javax.jms.QueueSender

Parameters:

queue -

message -

Throws:

javax.jms.JMSException

See Also:

QueueSender.send(javax.jms.Queue, javax.jms.Message)

send

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

Specified by:

send in interface javax.jms.QueueSender

Parameters:

queue -

message -

deliveryMode -

priority -

timeToLive -

Throws:

javax.jms.JMSException

See Also:

QueueSender.send(javax.jms.Queue, javax.jms.Message, int, int, long)