Stilts 0.1.0-SNAPSHOT

Class SimpleQueueStomplet

  extended by org.projectodd.stilts.stomplet.helpers.AbstractStomplet
      extended by org.projectodd.stilts.stomplet.simple.SimpleSubscribableStomplet
          extended by org.projectodd.stilts.stomplet.simple.SimpleQueueStomplet
All Implemented Interfaces:
MessageSink, AcknowledgeableStomplet, Stomplet

public class SimpleQueueStomplet
extends SimpleSubscribableStomplet
implements AcknowledgeableStomplet

Constructor Summary
Method Summary
 void ack(Subscriber subscriber, StompMessage message)
 void nack(Subscriber subscriber, StompMessage message)
 void onMessage(StompMessage message)
          Handle a message sent to a destination matched by this stomplet.
Methods inherited from class org.projectodd.stilts.stomplet.simple.SimpleSubscribableStomplet
onSubscribe, onUnsubscribe, send, sendToAllSubscribers, sendToOneSubscriber
Methods inherited from class org.projectodd.stilts.stomplet.helpers.AbstractStomplet
destroy, getStompletConfig, initialize, initialize
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.projectodd.stilts.stomplet.Stomplet
destroy, initialize, onSubscribe, onUnsubscribe

Constructor Detail


public SimpleQueueStomplet()
Method Detail


public void onMessage(StompMessage message)
               throws StompException
Description copied from interface: Stomplet
Handle a message sent to a destination matched by this stomplet.

In the event the stomplet is servicing multiple destinations, the stomplet may need to inspect the StompMessage for details as to how to handle the incoming message.

If named-segments are present in the applicable routing rule, each named segment is added to the message's header values, prefixed with stomplet..

For instance, the following routing rule:

 ROUTE /queues/:queue_name com.mycorp.MyStomplet

Would result in all inbound messages with matching destinations to have a header named stomplet.queue_name added to it, with the value being the matching portion of the destination.

Specified by:
onMessage in interface Stomplet
message - The inbound message.
StompException - If an error occurs while processing the message.


public void ack(Subscriber subscriber,
                StompMessage message)
Specified by:
ack in interface AcknowledgeableStomplet


public void nack(Subscriber subscriber,
                 StompMessage message)
Specified by:
nack in interface AcknowledgeableStomplet

Stilts 0.1.0-SNAPSHOT

Copyright © 2011 JBoss, a division of Red Hat, Inc.. All Rights Reserved.