Java Doc for MuxChannel.java in  » Net » JGroups-2.4.1-sp3 » org » jgroups » mux » Java Source Code / Java DocumentationJava Source Code and Java Documentation

Java Source Code / Java Documentation 1.  6.0 JDK Core 2.  6.0 JDK Modules 3.  6.0 JDK Modules com.sun 4.  6.0 JDK Modules com.sun.java 5.  6.0 JDK Modules sun 6.  6.0 JDK Platform 7.  Ajax 8.  Apache Harmony Java SE 9.  Aspect oriented 10.  Authentication Authorization 11.  Blogger System 12.  Build 13.  Byte Code 14.  Cache 15.  Chart 16.  Chat 17.  Code Analyzer 18.  Collaboration 19.  Content Management System 20.  Database Client 21.  Database DBMS 22.  Database JDBC Connection Pool 23.  Database ORM 24.  Development 25.  EJB Server geronimo 26.  EJB Server GlassFish 27.  EJB Server JBoss 4.2.1 28.  EJB Server resin 3.1.5 29.  ERP CRM Financial 30.  ESB 31.  Forum 32.  GIS 33.  Graphic Library 34.  Groupware 35.  HTML Parser 36.  IDE 37.  IDE Eclipse 38.  IDE Netbeans 39.  Installer 40.  Internationalization Localization 41.  Inversion of Control 42.  Issue Tracking 43.  J2EE 44.  JBoss 45.  JMS 46.  JMX 47.  Library 48.  Mail Clients 49.  Net 50.  Parser 51.  PDF 52.  Portal 53.  Profiler 54.  Project Management 55.  Report 56.  RSS RDF 57.  Rule Engine 58.  Science 59.  Scripting 60.  Search Engine 61.  Security 62.  Sevlet Container 63.  Source Control 64.  Swing Library 65.  Template Engine 66.  Test Coverage 67.  Testing 68.  UML 69.  Web Crawler 70.  Web Framework 71.  Web Mail 72.  Web Server 73.  Web Services 74.  Web Services apache cxf 2.0.1 75.  Web Services AXIS2 76.  Wiki Engine 77.  Workflow Engines 78.  XML 79.  XML UI Java Java Tutorial Java Open Source Jar File Download Java Articles Java Products Java by API Photoshop Tutorials Maya Tutorials Flash Tutorials 3ds-Max Tutorials Illustrator Tutorials GIMP Tutorials C# / C Sharp C# / CSharp Tutorial C# / CSharp Open Source ASP.Net ASP.NET Tutorial JavaScript DHTML JavaScript Tutorial JavaScript Reference HTML / CSS HTML CSS Reference C / ANSI-C C Tutorial C++ C++ Tutorial Ruby PHP Python Python Tutorial Python Open Source SQL Server / T-SQL SQL Server / T-SQL Tutorial Oracle PL / SQL Oracle PL/SQL Tutorial PostgreSQL SQL / MySQL MySQL Tutorial VB.Net VB.Net Tutorial Flash / Flex / ActionScript VBA / Excel / Access / Word XML XML Tutorial Microsoft Office PowerPoint 2007 Tutorial Microsoft Office Excel 2007 Tutorial Microsoft Office Word 2007 Tutorial

Java Source Code / Java Documentation » Net » JGroups 2.4.1 sp3 » org.jgroups.mux   Source Cross Reference   Class Diagram   Java Document (Java Doc)   java.lang.Object    org.jgroups.Channel       org.jgroups.JChannel          org.jgroups.mux.MuxChannel MuxChannel public class MuxChannel extends JChannel (Code) Multiplexer channel. This is returned as result of calling org.jgroups.ChannelFactory.createMultiplexerChannel(StringStringbooleanString) . Maintains the multiplexer ID, which is used to add a header to each message, so that the message can be demultiplexed at the receiver author:    Bela Ban version:    $Id: MuxChannel.java,v 1.26.2.1 2007/01/08 21:00:16 vlada Exp $ Field Summary final  JChannel ch      final  JChannelFactory factory      final  MuxHeader hdr      final  String id      final  Multiplexer mux      final  String name      final  String stack_name      The name of the JGroups stack, e.g. Constructor Summary public   MuxChannel(JChannelFactory f, JChannel ch, String id, String stack_name, Multiplexer mux)      Method Summary protected  void _close(boolean disconnect, boolean close_mq)      protected  void checkClosed()      protected  void checkNotConnected()      public synchronized  void close()      public synchronized  void connect(String channel_name)      public synchronized  boolean connect(String cluster_name, Address target, String state_id, long timeout)      public synchronized  void disconnect()      public  void down(Event evt)      public  Map dumpStats()      public  JChannel getChannel()      public  String getChannelName()      public  String getClusterName()      public  View getClusterView()      Returns the JGroups view of a cluster, e.g. public  String getId()      public  Address getLocalAddress()      public  Multiplexer getMultiplexer()      public  Object getOpt(int option)      public  ProtocolStack getProtocolStack()      public  String getStackName()      public  boolean getState(Address target, long timeout)      public  boolean getState(Address target, String state_id, long timeout)      public  View getView()      Returns the service view, ie. public  boolean isConnected()      public  boolean isOpen()      public synchronized  void open()      public  void returnState(byte[] state)      public  void returnState(byte[] state, String state_id)      public  void send(Message msg)      public  void send(Address dst, Address src, Serializable obj)      public  void setClosed(boolean f)      public  void setConnected(boolean f)      public  void setOpt(int option, Object value)      public synchronized  void shutdown()      Field Detail ch final JChannel ch(Code) the real channel to delegate to factory final JChannelFactory factory(Code) a reference back to the factory that created us hdr final MuxHeader hdr(Code) will be added to each message sent id final String id(Code) The service ID mux final Multiplexer mux(Code) name final String name(Code) stack_name final String stack_name(Code) The name of the JGroups stack, e.g. as defined in stacks.xml Constructor Detail MuxChannel public MuxChannel(JChannelFactory f, JChannel ch, String id, String stack_name, Multiplexer mux)(Code) Method Detail _close protected void _close(boolean disconnect, boolean close_mq)(Code) checkClosed protected void checkClosed() throws ChannelClosedException(Code) checkNotConnected protected void checkNotConnected() throws ChannelNotConnectedException(Code) close public synchronized void close()(Code) connect public synchronized void connect(String channel_name) throws ChannelException, ChannelClosedException(Code) connect public synchronized boolean connect(String cluster_name, Address target, String state_id, long timeout) throws ChannelException(Code) disconnect public synchronized void disconnect()(Code) down public void down(Event evt)(Code) dumpStats public Map dumpStats()(Code) getChannel public JChannel getChannel()(Code) This should never be used (just for testing) ! getChannelName public String getChannelName()(Code) getClusterName public String getClusterName()(Code) getClusterView public View getClusterView()(Code) Returns the JGroups view of a cluster, e.g. if we have nodes A, B and C, then the view will be {A,B,C} The JGroups view getId public String getId()(Code) getLocalAddress public Address getLocalAddress()(Code) getMultiplexer public Multiplexer getMultiplexer()(Code) getOpt public Object getOpt(int option)(Code) getProtocolStack public ProtocolStack getProtocolStack()(Code) getStackName public String getStackName()(Code) getState public boolean getState(Address target, long timeout) throws ChannelNotConnectedException, ChannelClosedException(Code) getState public boolean getState(Address target, String state_id, long timeout) throws ChannelNotConnectedException, ChannelClosedException(Code) getView public View getView()(Code) Returns the service view, ie. the cluster view (see MuxChannel.getView() ) minus the nodes on which this service is not running, e.g. if S1 runs on A and C, and the cluster view is {A,B,C}, then the service view is {A,C} The service view (list of nodes on which this service is running) isConnected public boolean isConnected()(Code) isOpen public boolean isOpen()(Code) open public synchronized void open() throws ChannelException(Code) returnState public void returnState(byte[] state)(Code) returnState public void returnState(byte[] state, String state_id)(Code) send public void send(Message msg) throws ChannelNotConnectedException, ChannelClosedException(Code) send public void send(Address dst, Address src, Serializable obj) throws ChannelNotConnectedException, ChannelClosedException(Code) setClosed public void setClosed(boolean f)(Code) setConnected public void setConnected(boolean f)(Code) setOpt public void setOpt(int option, Object value)(Code) shutdown public synchronized void shutdown()(Code) Fields inherited from org.jgroups.JChannel final public static String DEFAULT_PROTOCOL_STACK(Code)(Java Doc) protected boolean closed(Code)(Java Doc) protected CloserThread closer(Code)(Java Doc) protected boolean connected(Code)(Java Doc) final protected Log log(Code)(Java Doc) protected long sent_msgsreceived_msgssent_bytesreceived_bytes(Code)(Java Doc) protected boolean stats(Code)(Java Doc) Methods inherited from org.jgroups.JChannel protected void _close(boolean disconnect, boolean close_mq)(Code)(Java Doc) public void blockOk()(Code)(Java Doc) protected void checkClosed() throws ChannelClosedException(Code)(Java Doc) protected void checkNotConnected() throws ChannelNotConnectedException(Code)(Java Doc) public synchronized void close()(Code)(Java Doc) final public void closeMessageQueue(boolean flush_entries)(Code)(Java Doc) public synchronized void connect(String cluster_name) throws ChannelException, ChannelClosedException(Code)(Java Doc) public synchronized boolean connect(String cluster_name, Address target, String state_id, long timeout) throws ChannelException(Code)(Java Doc) public synchronized void disconnect()(Code)(Java Doc) public void down(Event evt)(Code)(Java Doc) public String dumpQueue()(Code)(Java Doc) public Map dumpStats()(Code)(Java Doc) public String dumpTimerQueue()(Code)(Java Doc) public void enableStats(boolean stats)(Code)(Java Doc) public boolean flushSupported()(Code)(Java Doc) public boolean getAllStates(Vector targets, long timeout) throws ChannelNotConnectedException, ChannelClosedException(Code)(Java Doc) public String getChannelName()(Code)(Java Doc) public String getClusterName()(Code)(Java Doc) public Address getLocalAddress()(Code)(Java Doc) protected Log getLog()(Code)(Java Doc) public int getNumMessages()(Code)(Java Doc) public int getNumberOfTasksInTimer()(Code)(Java Doc) public Object getOpt(int option)(Code)(Java Doc) public String getProperties()(Code)(Java Doc) public ProtocolStack getProtocolStack()(Code)(Java Doc) public long getReceivedBytes()(Code)(Java Doc) public long getReceivedMessages()(Code)(Java Doc) public long getSentBytes()(Code)(Java Doc) public long getSentMessages()(Code)(Java Doc) public boolean getState(Address target, long timeout) throws ChannelNotConnectedException, ChannelClosedException(Code)(Java Doc) public boolean getState(Address target, String state_id, long timeout) throws ChannelNotConnectedException, ChannelClosedException(Code)(Java Doc) public View getView()(Code)(Java Doc) final protected void init(ProtocolStackConfigurator configurator) throws ChannelException(Code)(Java Doc) public boolean isConnected()(Code)(Java Doc) public boolean isOpen()(Code)(Java Doc) public synchronized void open() throws ChannelException(Code)(Java Doc) public Object peek(long timeout) throws ChannelNotConnectedException, ChannelClosedException, TimeoutException(Code)(Java Doc) public String printProtocolSpec(boolean include_properties)(Code)(Java Doc) public Object receive(long timeout) throws ChannelNotConnectedException, ChannelClosedException, TimeoutException(Code)(Java Doc) public void resetStats()(Code)(Java Doc) public void returnState(byte[] state)(Code)(Java Doc) public void returnState(byte[] state, String state_id)(Code)(Java Doc) public void send(Message msg) throws ChannelNotConnectedException, ChannelClosedException(Code)(Java Doc) public void send(Address dst, Address src, Serializable obj) throws ChannelNotConnectedException, ChannelClosedException(Code)(Java Doc) public void setOpt(int option, Object value)(Code)(Java Doc) public synchronized void shutdown()(Code)(Java Doc) public boolean startFlush(long timeout, int numberOfAttempts, boolean automatic_resume)(Code)(Java Doc) public boolean startFlush(long timeout, boolean automatic_resume)(Code)(Java Doc) public boolean statsEnabled()(Code)(Java Doc) public void stopFlush()(Code)(Java Doc) public String toString(boolean details)(Code)(Java Doc) public void up(Event evt)(Code)(Java Doc) Fields inherited from org.jgroups.Channel final public static int AUTO_GETSTATE(Code)(Java Doc) final public static int AUTO_RECONNECT(Code)(Java Doc) final public static int BLOCK(Code)(Java Doc) final public static int GET_STATE_EVENTS(Code)(Java Doc) final public static int LOCAL(Code)(Java Doc) final public static int SUSPECT(Code)(Java Doc) final public static int VIEW(Code)(Java Doc) protected ChannelListener channel_listener(Code)(Java Doc) protected Set channel_listeners(Code)(Java Doc) protected Receiver receiver(Code)(Java Doc) protected UpHandler up_handler(Code)(Java Doc) Methods inherited from org.jgroups.Channel public synchronized void addChannelListener(ChannelListener listener)(Code)(Java Doc) abstract public void blockOk()(Code)(Java Doc) abstract public void close()(Code)(Java Doc) abstract public void connect(String cluster_name) throws ChannelException, ChannelClosedException(Code)(Java Doc) abstract public boolean connect(String cluster_name, Address target, String state_id, long timeout) throws ChannelException(Code)(Java Doc) abstract public void disconnect()(Code)(Java Doc) public void down(Event evt)(Code)(Java Doc) public String dumpQueue()(Code)(Java Doc) abstract public Map dumpStats()(Code)(Java Doc) abstract public boolean flushSupported()(Code)(Java Doc) abstract public boolean getAllStates(Vector targets, long timeout) throws ChannelNotConnectedException, ChannelClosedException(Code)(Java Doc) abstract public String getChannelName()(Code)(Java Doc) abstract public String getClusterName()(Code)(Java Doc) abstract public Address getLocalAddress()(Code)(Java Doc) abstract protected Log getLog()(Code)(Java Doc) public int getNumMessages()(Code)(Java Doc) abstract public Object getOpt(int option)(Code)(Java Doc) abstract public boolean getState(Address target, long timeout) throws ChannelNotConnectedException, ChannelClosedException(Code)(Java Doc) abstract public boolean getState(Address target, String state_id, long timeout) throws ChannelNotConnectedException, ChannelClosedException(Code)(Java Doc) abstract public View getView()(Code)(Java Doc) abstract public boolean isConnected()(Code)(Java Doc) abstract public boolean isOpen()(Code)(Java Doc) protected void notifyChannelClosed(Channel c)(Code)(Java Doc) protected void notifyChannelConnected(Channel c)(Code)(Java Doc) protected void notifyChannelDisconnected(Channel c)(Code)(Java Doc) protected void notifyChannelReconnected(Address addr)(Code)(Java Doc) protected void notifyChannelShunned()(Code)(Java Doc) public void open() throws ChannelException(Code)(Java Doc) public static String option2String(int option)(Code)(Java Doc) abstract public Object peek(long timeout) throws ChannelNotConnectedException, ChannelClosedException, TimeoutException(Code)(Java Doc) abstract public Object receive(long timeout) throws ChannelNotConnectedException, ChannelClosedException, TimeoutException(Code)(Java Doc) public synchronized void removeChannelListener(ChannelListener listener)(Code)(Java Doc) abstract public void returnState(byte[] state)(Code)(Java Doc) abstract public void returnState(byte[] state, String state_id)(Code)(Java Doc) abstract public void send(Message msg) throws ChannelNotConnectedException, ChannelClosedException(Code)(Java Doc) abstract public void send(Address dst, Address src, Serializable obj) throws ChannelNotConnectedException, ChannelClosedException(Code)(Java Doc) public void setChannelListener(ChannelListener channel_listener)(Code)(Java Doc) abstract public void setOpt(int option, Object value)(Code)(Java Doc) public void setReceiver(Receiver r)(Code)(Java Doc) public void setUpHandler(UpHandler up_handler)(Code)(Java Doc) abstract protected void shutdown()(Code)(Java Doc) abstract public boolean startFlush(long timeout, boolean automatic_resume)(Code)(Java Doc) abstract public void stopFlush()(Code)(Java Doc) Methods inherited from java.lang.Object native protected Object clone() throws CloneNotSupportedException(Code)(Java Doc) public boolean equals(Object obj)(Code)(Java Doc) protected void finalize() throws Throwable(Code)(Java Doc) final native public Class getClass()(Code)(Java Doc) native public int hashCode()(Code)(Java Doc) final native public void notify()(Code)(Java Doc) final native public void notifyAll()(Code)(Java Doc) public String toString()(Code)(Java Doc) final native public void wait(long timeout) throws InterruptedException(Code)(Java Doc) final public void wait(long timeout, int nanos) throws InterruptedException(Code)(Java Doc) final public void wait() throws InterruptedException(Code)(Java Doc)