org.apache.synapse.transport.pipe
Class PipeDispatcher

java.lang.Object
  org.apache.synapse.transport.pipe.PipeDispatcher

All Implemented Interfaces:

org.apache.axis2.transport.base.datagram.DatagramDispatcher<PipeEndpoint>

public class PipeDispatcher
extends Object
implements org.apache.axis2.transport.base.datagram.DatagramDispatcher<PipeEndpoint>

DatagramDispatcher implementation for the pipe transport.

Constructor Summary

PipeDispatcher(org.apache.axis2.transport.base.datagram.DatagramDispatcherCallback callback)

Method Summary

void	addEndpoint(PipeEndpoint endpoint)
void	removeEndpoint(PipeEndpoint endpoint)
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

PipeDispatcher

public PipeDispatcher(org.apache.axis2.transport.base.datagram.DatagramDispatcherCallback callback)

Method Detail

addEndpoint

public void addEndpoint(PipeEndpoint endpoint)
                 throws IOException

Specified by:

addEndpoint in interface org.apache.axis2.transport.base.datagram.DatagramDispatcher<PipeEndpoint>

Throws:

IOException

removeEndpoint

public void removeEndpoint(PipeEndpoint endpoint)
                    throws IOException

Specified by:

removeEndpoint in interface org.apache.axis2.transport.base.datagram.DatagramDispatcher<PipeEndpoint>

Throws:

IOException

stop

public void stop()
          throws IOException

Specified by:

stop in interface org.apache.axis2.transport.base.datagram.DatagramDispatcher<PipeEndpoint>

Throws:

IOException