KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > com > ubermq > jms > common > routing > impl > ConnectionDestNode


1 package com.ubermq.jms.common.routing.impl;
2
3 import com.ubermq.jms.common.routing.*;
4 import com.ubermq.kernel.*;
5 import java.io.*;
6
7 /**
8  * Implements a destination that contains information about a connected peer.
9  * The message server will use this information from the router to forward
10  * messages to their logical destinations.
11  */
12 public class ConnectionDestNode
13     implements RouteDestNode, DatagramSink, Comparable JavaDoc, java.io.Serializable JavaDoc
14 {
15     private IConnectionInfo conn;
16
17     public ConnectionDestNode(IConnectionInfo ci) {this.conn = ci;}
18
19     public final IConnectionInfo getConnection() {return conn;}
20
21     public boolean isOpen() {return getConnection().isOpen();}
22
23     public void output(IDatagram d, IOverflowHandler h)
24         throws IOException
25     {
26         conn.output(d, h);
27     }
28
29     public String JavaDoc getDisplayName() {return conn.toString();}
30     public String JavaDoc getNodeName() {return conn.getId();}
31     public String JavaDoc toString() {return conn.toString();}
32
33     public boolean equals(Object JavaDoc o)
34     {
35         if (o instanceof RouteDestNode) {
36             return (getNodeName().equals(((RouteDestNode)o).getNodeName()));
37         } else {
38             return false;
39         }
40     }
41
42     public int compareTo(Object JavaDoc obj)
43         throws ClassCastException JavaDoc
44     {
45         RouteDestNode dn = (RouteDestNode)obj;
46         return (getNodeName().compareTo(dn.getNodeName()));
47     }
48
49     public int hashCode() {return getNodeName().hashCode();}
50 }
51
52
Popular Tags