|
||||||||||
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.SocketManagerIPChunkBasedImpl
Socket manager that retrieves sockets using an IPSocketManager
and
getting IP and port in a IPChannelDestinationChunk
in messages.
Field Summary | |
protected IPSocketManager |
delegateSocketManagerItf
|
protected boolean |
deleteChunk
|
protected String |
destinationChunkName
|
protected MessageManager |
messageManagerItf
|
Fields inherited from class org.objectweb.dream.AbstractComponent |
bindingLogger, componentDesc, fcState, firstStart, lifeCycleLogger, logger, weaveableC |
Fields inherited from interface org.objectweb.dream.channel.SocketManager |
ITF_NAME |
Fields inherited from interface org.objectweb.fractal.api.control.LifeCycleController |
STARTED, STOPPED |
Constructor Summary | |
SocketManagerIPChunkBasedImpl()
|
Method Summary | |
void |
bindFc(String clientItfName,
Object serverItf)
|
boolean |
getDeleteChunk()
Returns true if the destination chunk should be deleted from
the message. |
String |
getDestinationChunkName()
Returns the name of the chunks that contains the destination identification of the message. |
SocketState |
getSocket(Message message)
Returns a socket that can be used to send message to a ChannelIn |
String[] |
listFc()
|
void |
releaseSocket(SocketState socketState,
boolean error)
Releases the given SocketState . |
void |
setDeleteChunk(boolean deleteChunk)
Set if the destination chunk should be deleted from the message. |
void |
setDestinationChunkName(String destinationChunkName)
Set the name of the chunks that contains the destination identification of the message. |
Methods inherited from class org.objectweb.dream.AbstractComponent |
beforeFirstStart, 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 |
Field Detail |
protected boolean deleteChunk
protected String destinationChunkName
protected MessageManager messageManagerItf
protected IPSocketManager delegateSocketManagerItf
Constructor Detail |
public SocketManagerIPChunkBasedImpl()
Method Detail |
public SocketState getSocket(Message message) throws IOException, InterruptedException
SocketManager
getSocket
in interface SocketManager
message
- a message that is going to be sent to a ChannelIn
InterruptedException
- if the component is interrupted while waiting.
IOException
- if the socket can't be opened.SocketManager.getSocket(Message)
public void releaseSocket(SocketState socketState, boolean error)
SocketManager
SocketState
.
releaseSocket
in interface SocketManager
socketState
- the socket state to release.error
- true
if an exception has been catched while
sending the message, false
otherwise.SocketManager.releaseSocket(SocketState, boolean)
public boolean getDeleteChunk()
SocketManagerIPChunkBasedAttributeController
true
if the destination chunk should be deleted from
the message. The default value is true
getDeleteChunk
in interface SocketManagerIPChunkBasedAttributeController
true
if the destination chunk should be deleted from
the message.SocketManagerIPChunkBasedAttributeController.getDeleteChunk()
public void setDeleteChunk(boolean deleteChunk)
SocketManagerIPChunkBasedAttributeController
setDeleteChunk
in interface SocketManagerIPChunkBasedAttributeController
deleteChunk
- true
if the destination chunk should be
deleted from the message.SocketManagerIPChunkBasedAttributeController.setDeleteChunk(boolean)
public String getDestinationChunkName()
SocketManagerIPChunkBasedAttributeController
getDestinationChunkName
in interface SocketManagerIPChunkBasedAttributeController
SocketManagerIPChunkBasedAttributeController.getDestinationChunkName()
public void setDestinationChunkName(String destinationChunkName)
SocketManagerIPChunkBasedAttributeController
setDestinationChunkName
in interface SocketManagerIPChunkBasedAttributeController
destinationChunkName
- a chunk name.SocketManagerIPChunkBasedAttributeController.setDestinationChunkName(String)
public String[] listFc()
listFc
in interface BindingController
BindingController.listFc()
public void bindFc(String clientItfName, Object serverItf) throws NoSuchInterfaceException, IllegalBindingException, IllegalLifeCycleException
bindFc
in interface BindingController
NoSuchInterfaceException
IllegalBindingException
IllegalLifeCycleException
BindingController.bindFc(String,
Object)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |