Can anyone see anything wrong with my remote setup using JBoss 3.0.2. I'm
getting the following exceptions below from a remote client that tries to
create or delete a queue using the RMIAdapter ...
javax.naming.CommunicationException: Peek timed out. Root exception is
java.io.InterruptedIOException: Peek timed out
at java.net.PlainDatagramSocketImpl.peek(Native Method)
at java.net.DatagramSocket.receive(DatagramSocket.java:349)
at org.jnp.interfaces.NamingContext.discoverServer(NamingContext.java:930)
at org.jnp.interfaces.NamingContext.checkRef(NamingContext.java:1017)
at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:447)
at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:440)
at javax.naming.InitialContext.lookup(InitialContext.java:345)
at com.neuroquest.cais.clients.fielder.Fielder.createPTP(Unknown Source)
at com.neuroquest.cais.clients.fielder.Fielder.main(Unknown Source)
Here is the jndi.properties which I have in the classpath and don't
recognize any problems with.
java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory
java.naming.provider.url=jnp://192.168.0.10:1099/
java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces
#jnp.socketFactory=org.jnp.interfaces.TimedSocketFactory
#jnp.timeout=0
#jnp.sotimeout=0
And here is the code I'm trying to use 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);
...
Any help much appreciated.
-------------------------------------------------------
This sf.net email is sponsored by: To learn the basics of securing
your web site with SSL, click here to get a FREE TRIAL of a Thawte
Server Certificate: http://www.gothawte.com/rd524.html
_______________________________________________
JBoss-user mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-user
