com.sun.enterprise.mgmt.transport.jxta
Class JxtaPipeManager

java.lang.Object
  com.sun.enterprise.mgmt.transport.jxta.JxtaPipeManager

public class JxtaPipeManager
extends Object

This class manages Jxta's InputPipe and OutputPipe and sends Jxta's message through JxtaUtility This stores and caches Jxta's OutputPipe according to Jxta's PeerID

Author:

Bongjae Chang

Constructor Summary

JxtaPipeManager(JxtaNetworkManager networkManager, PipeService pipeService, PipeAdvertisement pipeAdv, PipeMsgListener pipeMsgListener)

Method Summary

boolean	broadcast(net.jxta.endpoint.Message message)
void	clearPipeCache()
void	removePipeFromCache(net.jxta.peer.PeerID peerid) in the event of a failure or planned shutdown, remove the pipe from the pipeCache
boolean	send(net.jxta.peer.PeerID peerid, net.jxta.endpoint.Message message)
void	start()
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JxtaPipeManager

public JxtaPipeManager(JxtaNetworkManager networkManager,
                       PipeService pipeService,
                       PipeAdvertisement pipeAdv,
                       PipeMsgListener pipeMsgListener)

Method Detail

start

public void start()

stop

public void stop()

removePipeFromCache

public void removePipeFromCache(net.jxta.peer.PeerID peerid)

in the event of a failure or planned shutdown, remove the pipe from the pipeCache

Parameters:

peerid - peerID

clearPipeCache

public void clearPipeCache()

send

public boolean send(net.jxta.peer.PeerID peerid,
                    net.jxta.endpoint.Message message)
             throws IOException

Throws:

IOException

broadcast

public boolean broadcast(net.jxta.endpoint.Message message)
                  throws IOException

Throws:

IOException