org.projectodd.stilts.stomplet.simple
Class SimpleTopicStomplet

java.lang.Object
  org.projectodd.stilts.stomplet.helpers.AbstractStomplet
      org.projectodd.stilts.stomplet.simple.SimpleSubscribableStomplet
          org.projectodd.stilts.stomplet.simple.SimpleTopicStomplet

All Implemented Interfaces:

MessageSink, Stomplet

public class SimpleTopicStomplet
extends SimpleSubscribableStomplet

Constructor Summary

SimpleTopicStomplet()

Method Summary

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

Constructor Detail

SimpleTopicStomplet

public SimpleTopicStomplet()

Method Detail

onMessage

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.

Parameters:

message - The inbound message.

Throws:

StompException - If an error occurs while processing the message.