|
Project JXTA | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.jxta.impl.endpoint.cbjx.CbJxTransport
public class CbJxTransport
A JXTA MessageTransport
implementation which
which provides message verification by examining message signatures. A
virtual transport, the messages are transfered between peers using some
other message transport.
Nested Class Summary | |
---|---|
class |
CbJxTransport.CbJxInputFilter
this class filters incoming messages. |
class |
CbJxTransport.CbJxOutputFilter
this class filters all outgoing messages that are not sent with messengers. |
Field Summary | |
---|---|
(package private) static String |
CBJX_MSG_BODY
the name of the cbjx body element |
(package private) static String |
CBJX_MSG_INFO
the name of the cbjx crypto element |
static String |
CBJX_MSG_NS
the name of the cbjx valid element |
(package private) static String |
CBJX_MSG_SIG
the name of the cbjx body element |
(package private) static String |
cbjxProtocolName
the cbjx protocol name |
(package private) static String |
cbjxServiceName
the cbjx service name |
(package private) EndpointService |
endpoint
the endpoint service in my group |
(package private) PeerGroup |
group
the peer group to which this module belongs |
(package private) static EndpointAddress |
localPeerAddr
the endpoint address of this peer |
(package private) static PeerID |
localPeerID
the local peer ID |
(package private) PSEMembershipService |
membership
the membership service in my group |
Fields inherited from interface net.jxta.platform.Module |
---|
START_AGAIN_PROGRESS, START_AGAIN_STALLED, START_OK |
Constructor Summary | |
---|---|
CbJxTransport()
Default constructor |
Method Summary | |
---|---|
Message |
addCryptoInfo(Message submessage,
EndpointAddress destAddress)
add the CryptoInfo into the message |
boolean |
allowsRouting()
|
Message |
checkCryptoInfo(Message message,
MessageElement cryptoElement,
CbJxMessageInfo cryptoInfo)
|
EndpointService |
getEndpointService()
|
Messenger |
getMessenger(EndpointAddress dest,
Object hintIgnored)
|
String |
getProtocolName()
|
EndpointAddress |
getPublicAddress()
|
Iterator |
getPublicAddresses()
|
void |
init(PeerGroup group,
ID assignedID,
Advertisement impl)
|
boolean |
isConnectionOriented()
|
boolean |
isPropagateEnabled()
(@inheritdoc} |
boolean |
isPropagationSupported()
(@inheritdoc} |
boolean |
ping(EndpointAddress addr)
|
void |
processIncomingMessage(Message message,
EndpointAddress srcAddr,
EndpointAddress dstAddr)
|
void |
propagate(Message msg,
String serviceName,
String serviceParams,
String prunePeer)
|
int |
startApp(String[] arg)
|
void |
stopApp()
|
Object |
transportControl(Object operation,
Object value)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final String CBJX_MSG_NS
static final String CBJX_MSG_INFO
static final String CBJX_MSG_BODY
static final String CBJX_MSG_SIG
static final String cbjxProtocolName
static final String cbjxServiceName
static PeerID localPeerID
static EndpointAddress localPeerAddr
PeerGroup group
EndpointService endpoint
PSEMembershipService membership
Constructor Detail |
---|
public CbJxTransport()
Method Detail |
---|
public void init(PeerGroup group, ID assignedID, Advertisement impl) throws PeerGroupException
init
in interface Module
PeerGroupException
public int startApp(String[] arg)
startApp
in interface Module
public void stopApp()
stopApp
in interface Module
public EndpointAddress getPublicAddress()
getPublicAddress
in interface MessageSender
public boolean isConnectionOriented()
isConnectionOriented
in interface MessageSender
public boolean allowsRouting()
allowsRouting
in interface MessageSender
public EndpointService getEndpointService()
getEndpointService
in interface MessageTransport
public Object transportControl(Object operation, Object value)
transportControl
in interface MessageTransport
public Iterator getPublicAddresses()
getPublicAddresses
in interface MessageReceiver
public String getProtocolName()
getProtocolName
in interface MessageTransport
public Messenger getMessenger(EndpointAddress dest, Object hintIgnored)
getMessenger
in interface MessageSender
public boolean isPropagateEnabled()
isPropagateEnabled
in interface MessageSender
public boolean isPropagationSupported()
isPropagationSupported
in interface MessageSender
public void propagate(Message msg, String serviceName, String serviceParams, String prunePeer) throws IOException
propagate
in interface MessageSender
IOException
public boolean ping(EndpointAddress addr)
ping
in interface MessageSender
public void processIncomingMessage(Message message, EndpointAddress srcAddr, EndpointAddress dstAddr)
processIncomingMessage
in interface EndpointListener
public Message addCryptoInfo(Message submessage, EndpointAddress destAddress) throws IOException
submessage
- the messagedestAddress
- the destination
IOException
public Message checkCryptoInfo(Message message, MessageElement cryptoElement, CbJxMessageInfo cryptoInfo)
|
JXTA J2SE | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |