-
1. Re: CommunicationException: Peek timed out.
garyg Nov 20, 2002 2:55 AM (in response to garyg)Just some more info if anyone has any ideas ... It was suggested by Scott that I do the telnet command below. I did and saw all this so the naming server is there ...
$ telnet 192.168.0.10 1099
Trying 192.168.0.10...
Connected to 192.168.0.10.
Escape character is '^]'.
¬í ♣sr ↓java.rmi.MarshalledObject|½▲-ícü>☻ ♥I ♦hash[locBytest ☻[B[objBytesq ~ ☺x
p§4Y↔ur ☻[B¬ó↨oTà☻ xp %¬í ♣t ¶http://banshee:8083/q ~ q ~ uq ~ ♥ A¬í ♣sr
org.jnp.server.NamingServer_Stub ☻☻ xr →java.rmi.server.RemoteStubé_ÜÉ<áe
→☻ xr ∟java.rmi.server.RemoteObjectOa'`♀a3▲♥ xpw7 ♂UnicastRef2 ♀172.17.66.55U
Any other ideas much appreciated. -
2. Re: CommunicationException: Peek timed out.
garyg Nov 22, 2002 1:10 AM (in response to garyg)And here's the code that I'm trying to connect to the server with (which destroys a queue if already registered, and then recreates it, for those cases where the client may go down) ...
// this is the jboss server I'm connecting to remotly
String adaptorName = "jmx:" + props.getProperty("fielder.manager") + ":rmi";
try {
InitialContext ctx = new InitialContext();
RMIAdaptor adaptor = (RMIAdaptor) ctx.lookup(adaptorName);
ObjectName name = new ObjectName("jboss.mq:service=DestinationManager");
RemoteMBeanServer server = new RMIConnectorImpl(adaptor);
ObjectName queName = new ObjectName("queue/myQueue");
boolean registered = server.isRegistered(queName);
String[] sig = {"java.lang.String"};
Object[] arg = {props.getProperty("myQueue")};
if (registered) {
log.info(Fielder.class, "already registered, destroying queue");
server.invoke(name, "destroyQueue", arg, sig);
}
log.info(Fielder.class, "creating queue");
server.invoke(name, "createQueue", arg, sig);
...