|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.dream.AbstractComponent
org.objectweb.dream.channel.AbstractTCPChannelOutImpl
org.objectweb.dream.channel.MonoDestinationTCPChannelOutImpl
Basic implementation of a ChannelOut component, using TCP protocol. Messages
are sent to one destination, which can be changed using the
controller.
Field Summary | |
protected InetAddress |
inetAddress
The inet address to which messages are sent. |
protected ObjectOutputStream |
oos
The output stram that is used to send messages. |
protected int |
port
The port to which messages are sent. |
protected Socket |
sock
The socket that is used to send messages. |
Fields inherited from class org.objectweb.dream.channel.AbstractTCPChannelOutImpl |
cnxRetry, messageCodecItf, messageManagerItf |
Fields inherited from class org.objectweb.dream.AbstractComponent |
bindingLogger, componentDesc, fcState, lifeCycleLogger, logger, weaveableC |
Fields inherited from interface org.objectweb.dream.Push |
IN_PUSH_ITF_NAME, OUT_PUSH_ITF_NAME |
Fields inherited from interface org.objectweb.fractal.api.control.LifeCycleController |
STARTED, STOPPED |
Constructor Summary | |
MonoDestinationTCPChannelOutImpl()
|
Method Summary | |
String |
getInetAddress()
Returns the inet address to which messages are sent. |
int |
getPort()
Returns the port number to which messages are sent. |
void |
push(Message message,
Map context)
|
protected void |
receiveAck(Socket sock)
Does not do anything. |
void |
setInetAddress(String inetAddress)
Sets the inet address to which messages are sent. |
void |
setPort(int port)
Sets the port number to which messages are sent. |
Methods inherited from class org.objectweb.dream.channel.AbstractTCPChannelOutImpl |
bindFc, closeSocket, connectSocket, getConnectionRetry, listFc, setConnectionRetry, setSocketOption |
Methods inherited from class org.objectweb.dream.AbstractComponent |
getFcState, initComponent, lookupFc, setLogger, startFc, stopFc, unbindFc |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.objectweb.dream.channel.ChannelOutAttributeController |
getConnectionRetry, setConnectionRetry |
Field Detail |
protected InetAddress inetAddress
protected int port
protected Socket sock
protected ObjectOutputStream oos
Constructor Detail |
public MonoDestinationTCPChannelOutImpl()
Method Detail |
public void push(Message message, Map context) throws PushException
push
in interface Push
PushException
Push.push(Message, Map)
public String getInetAddress()
MonoDestinationIPChannelOutAttributeController
getInetAddress
in interface MonoDestinationIPChannelOutAttributeController
MonoDestinationIPChannelOutAttributeController.getInetAddress()
public void setInetAddress(String inetAddress) throws UnknownHostException, IOException
MonoDestinationIPChannelOutAttributeController
setInetAddress
in interface MonoDestinationIPChannelOutAttributeController
inetAddress
- a String representing the inet address.
IOException
- if an error occurs while closing the previously used
socket.
UnknownHostException
- if the given inet address can't be resolved.MonoDestinationIPChannelOutAttributeController.setInetAddress(String)
public int getPort()
MonoDestinationIPChannelOutAttributeController
getPort
in interface MonoDestinationIPChannelOutAttributeController
MonoDestinationIPChannelOutAttributeController.getPort()
public void setPort(int port)
MonoDestinationIPChannelOutAttributeController
setPort
in interface MonoDestinationIPChannelOutAttributeController
port
- the port number to which messages are sent.MonoDestinationIPChannelOutAttributeController.setPort(int)
protected void receiveAck(Socket sock) throws IOException
sock
- the socket to be used.
IOException
- if an error occurs.
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |