org.objectweb.dream.channel
Class BasicTCPChannelOutImpl
java.lang.Object
org.objectweb.dream.AbstractComponent
org.objectweb.dream.channel.AbstractTCPChannelOutImpl
org.objectweb.dream.channel.BasicTCPChannelOutImpl
- All Implemented Interfaces:
- AttributeController, BindingController, ChannelOutAttributeController, LifeCycleController, Loggable, MultiDestinationChannelOutAttributeController, Push
- Direct Known Subclasses:
- ReliableTCPChannelOutImpl
- public class BasicTCPChannelOutImpl
- extends AbstractTCPChannelOutImpl
- implements MultiDestinationChannelOutAttributeController
Basic implementation of a ChannelOut component. TODO improve
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
chunkName
protected String chunkName
BasicTCPChannelOutImpl
public BasicTCPChannelOutImpl()
push
public void push(Message message,
Map context)
throws PushException
- Specified by:
push
in interface Push
- Throws:
PushException
- See Also:
Push.push(Message, Map)
getDestinationChunkName
public String getDestinationChunkName()
- Description copied from interface:
MultiDestinationChannelOutAttributeController
- Returns the name of the
IPChannelDestinationChunk
chunk used by ChannelOut.
- Specified by:
getDestinationChunkName
in interface MultiDestinationChannelOutAttributeController
- Returns:
- the name of the
IPChannelDestinationChunk
chunk used by ChannelOut. - See Also:
MultiDestinationChannelOutAttributeController.getDestinationChunkName()
setDestinationChunkName
public void setDestinationChunkName(String name)
- Description copied from interface:
MultiDestinationChannelOutAttributeController
- Sets the name of the
IPChannelDestinationChunk
chunk used by ChannelOut.
- Specified by:
setDestinationChunkName
in interface MultiDestinationChannelOutAttributeController
- Parameters:
name
- the name of the IPChannelDestinationChunk
chunk used by
ChannelOut.- See Also:
MultiDestinationChannelOutAttributeController.setDestinationChunkName(String)
receiveAck
protected void receiveAck(Socket sock)
throws IOException
- Does not do anything.
- Parameters:
sock
- the socket to be used.
- Throws:
IOException
- if an error occurs.
Copyright © 2003, 2004 - INRIA Rhone-Alpes - All Rights Reserved.