Project JXTA

net.jxta.impl.endpoint.servlethttp
Class HttpMessageSender

java.lang.Object
  extended by net.jxta.impl.endpoint.servlethttp.HttpMessageSender
All Implemented Interfaces:
MessageSender, MessageTransport

public class HttpMessageSender
extends Object
implements MessageSender

Simple MessageSender


Constructor Summary
HttpMessageSender(ServletHttpTransport servletHttpTransport, EndpointAddress publicAddress, PeerID peerId)
          constructor
 
Method Summary
 boolean allowsRouting()
          
 EndpointService getEndpointService()
          
 Messenger getMessenger(EndpointAddress destAddr, Object hintIgnored)
          
 String getProtocolName()
          
 EndpointAddress getPublicAddress()
          
 boolean isConnectionOriented()
          
 boolean isPropagateEnabled()
          (@inheritdoc}
 boolean isPropagationSupported()
          (@inheritdoc}
 boolean ping(EndpointAddress addr)
          
 void propagate(Message msg, String serviceName, String serviceParams, String prunePeer)
          
 void shutdown()
          shut down all client connections.
 Object transportControl(Object operation, Object Value)
          
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

HttpMessageSender

public HttpMessageSender(ServletHttpTransport servletHttpTransport,
                         EndpointAddress publicAddress,
                         PeerID peerId)
                  throws PeerGroupException
constructor

Throws:
PeerGroupException
Method Detail

getPublicAddress

public EndpointAddress getPublicAddress()

Specified by:
getPublicAddress in interface MessageSender

isConnectionOriented

public boolean isConnectionOriented()

Specified by:
isConnectionOriented in interface MessageSender

allowsRouting

public boolean allowsRouting()

Specified by:
allowsRouting in interface MessageSender

transportControl

public Object transportControl(Object operation,
                               Object Value)

Specified by:
transportControl in interface MessageTransport

shutdown

public void shutdown()
shut down all client connections.


getMessenger

public Messenger getMessenger(EndpointAddress destAddr,
                              Object hintIgnored)

Specified by:
getMessenger in interface MessageSender

isPropagateEnabled

public boolean isPropagateEnabled()
(@inheritdoc}

Specified by:
isPropagateEnabled in interface MessageSender

isPropagationSupported

public boolean isPropagationSupported()
(@inheritdoc}

Specified by:
isPropagationSupported in interface MessageSender

propagate

public void propagate(Message msg,
                      String serviceName,
                      String serviceParams,
                      String prunePeer)
               throws IOException

Specified by:
propagate in interface MessageSender
Throws:
IOException

ping

public boolean ping(EndpointAddress addr)

Specified by:
ping in interface MessageSender

getProtocolName

public String getProtocolName()

Specified by:
getProtocolName in interface MessageTransport

getEndpointService

public EndpointService getEndpointService()

Specified by:
getEndpointService in interface MessageTransport

JXTA J2SE