org.projectodd.stilts.stomp.server.protocol
Class ChannelMessageSink

java.lang.Object
  org.projectodd.stilts.stomp.server.protocol.ChannelMessageSink

All Implemented Interfaces:

MessageSink, TransactionalAcknowledgeableMessageSink

public class ChannelMessageSink
extends Object
implements TransactionalAcknowledgeableMessageSink

Constructor Summary

ChannelMessageSink(org.jboss.netty.channel.Channel channel, org.projectodd.stilts.stomp.server.protocol.AckManager ackManager)

Method Summary

void	send(StompMessage message)
void	send(StompMessage message, TransactionalAcknowledger acknowledger)

Methods inherited from class java.lang.Object

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

Constructor Detail

ChannelMessageSink

public ChannelMessageSink(org.jboss.netty.channel.Channel channel,
                          org.projectodd.stilts.stomp.server.protocol.AckManager ackManager)

Method Detail

send

public void send(StompMessage message)
          throws StompException

Specified by:

send in interface MessageSink

Throws:

StompException

send

public void send(StompMessage message,
                 TransactionalAcknowledger acknowledger)
          throws StompException

Specified by:

send in interface TransactionalAcknowledgeableMessageSink

Throws:

StompException