Class
Tree
          
SUMMARY: INNER | FIELD | CONSTR | METHODDETAIL: FIELD | CONSTR | METHOD
  
com.newstep.solid.netio.rtt
Class MessageFramingElement
com.newstep.solid.netio.ProtocolElement
  |
  +--com.newstep.solid.netio.rtt.MessageFramingElement
All Implemented Interfaces:
       StreamListener
public class MessageFramingElement      
Implements:
StreamListener
 
Links:
Kernel Association Association Link
to Class TcpStreamChannel
Associates type:
aggregationByValue
Client cardinality:
1
Client navigability:
NOT NAVIGABLE
Client visibility:
private
Directed.
Supplier cardinality:
1
Supplier navigability:
NAVIGABLE
Supplier visibility:
private
Custom properties
link:
aggregationByValue
 
Kernel Association Association Link
to Class ContinuityElement
Associates type:
aggregation
Client cardinality:
1
Client navigability:
NOT NAVIGABLE
Client visibility:
private
Directed.
Supplier cardinality:
1
Supplier navigability:
NAVIGABLE
Supplier visibility:
private
Custom properties
link:
aggregation
 
Kernel Association Association Link
to Class PayloadMessage
Associates type:
aggregation
Client cardinality:
1
Client navigability:
NOT NAVIGABLE
Client visibility:
private
Directed.
Supplier cardinality:
1
Supplier navigability:
NAVIGABLE
Supplier visibility:
private
Custom properties
link:
aggregation
 
Generalization Generalization Link
to Class ProtocolElement
 
Implementation Implementation Link
to Interface StreamListener
 
 
Field Summary
private ByteBuffer
private final static String
private ByteBuffer
private boolean
private boolean
protected static Logger
Constructor Summary
void
Method Summary
private void
private void
pushMessage(ByteBuffer h)
private void
pushMessage(PayloadMessage pm, ByteBuffer payload)
public void
void
public void
Field Detail
buffers
private ByteBuffer buffers
Multiplicity:
1
 
className
private final static String className
Final.
Multiplicity:
1
Static.
 
controlListener
private ContinuityElement controlListener
Multiplicity:
1
 
header
private ByteBuffer header
Multiplicity:
1
 
inHeader
private boolean inHeader
Multiplicity:
1
 
inPayload
private boolean inPayload
Multiplicity:
1
 
logger
protected static Logger logger
Multiplicity:
1
Static.
 
payloadMessage
private PayloadMessage payloadMessage
Multiplicity:
1
 
tcpChannel
private TcpStreamChannel tcpChannel
Multiplicity:
1
 
Constructor Detail
MessageFramingElement
void MessageFramingElement (ContinuityElement element)
 
Stereotype:
create
 
Method Detail
getTcpChannel
TcpStreamChannel getTcpChannel ()
 
 
headerReceived
private void headerReceived ()
 
After a full header has been received figures out whether it is a data or dataless message
and processes it accordingly
 
pushMessage
private void pushMessage (ByteBuffer h)
 
Creates a control or heartbeat message out of the received byte buffer and pushes it upstream
to the continuity element
Parameters:
h
byte buffer containing the header
 
pushMessage
private void pushMessage (PayloadMessage pm, ByteBuffer payload)
 
Attaches the payload to the previously created payload message and pushes it upstream to the
continuity element
Parameters:
pm
payload message created after the header was received
payload
payload byte buffer
 
readNotify
public void readNotify ()
 
 
setTcpChannel
void setTcpChannel (TcpStreamChannel channel)
 
 
write
public void write (ProtocolMessage message)
 
 
Class
Tree
          
SUMMARY: INNER | FIELD | CONSTR | METHODDETAIL: FIELD | CONSTR | METHOD