You are viewing a plain text version of this content. The canonical link for it is here.
Posted to cvs@avalon.apache.org by le...@apache.org on 2002/08/23 11:47:26 UTC
cvs commit: jakarta-avalon-excalibur/instrument-client/src/java/org/apache/excalibur/instrument/client InstrumentManagerConnection.java
leif 2002/08/23 02:47:26
Modified: instrument-client/src/java/org/apache/excalibur/instrument/client
InstrumentManagerConnection.java
Log:
Disable Altrmi auto reconnect.
Revision Changes Path
1.3 +10 -5 jakarta-avalon-excalibur/instrument-client/src/java/org/apache/excalibur/instrument/client/InstrumentManagerConnection.java
Index: InstrumentManagerConnection.java
===================================================================
RCS file: /home/cvs/jakarta-avalon-excalibur/instrument-client/src/java/org/apache/excalibur/instrument/client/InstrumentManagerConnection.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- InstrumentManagerConnection.java 22 Aug 2002 16:50:38 -0000 1.2
+++ InstrumentManagerConnection.java 23 Aug 2002 09:47:26 -0000 1.3
@@ -37,6 +37,7 @@
import org.apache.excalibur.altrmi.client.AltrmiFactory;
import org.apache.excalibur.altrmi.client.impl.socket.SocketCustomStreamHostContext;
import org.apache.excalibur.altrmi.client.impl.ClientClassAltrmiFactory;
+import org.apache.excalibur.altrmi.client.impl.DefaultConnectionListener;
import org.apache.excalibur.altrmi.common.AltrmiConnectionException;
import org.apache.excalibur.altrmi.common.AltrmiInvocationException;
@@ -352,9 +353,13 @@
getLogger().debug( "open()" );
synchronized (this)
{
- m_altrmiHostContext = new SocketCustomStreamHostContext( m_host, m_port );
+ SocketCustomStreamHostContext altrmiHostContext =
+ new SocketCustomStreamHostContext( m_host, m_port );
+ altrmiHostContext.setAltrmiConnectionListener( new DefaultConnectionListener( 0 ) );
+
+ m_altrmiHostContext = altrmiHostContext;
m_altrmiFactory = new ClientClassAltrmiFactory( false );
- m_altrmiFactory.setHostContext( m_altrmiHostContext );
+ m_altrmiFactory.setHostContext( altrmiHostContext );
/*
System.out.println("Listing Published Objects At Server...");
@@ -478,8 +483,8 @@
}
catch ( AltrmiInvocationException e )
{
- System.out.println("Ping Failed.");
- e.printStackTrace();
+ getLogger().debug( "Ping Failed.", e );
+
// Socket was closed.
close();
}
--
To unsubscribe, e-mail: <ma...@jakarta.apache.org>
For additional commands, e-mail: <ma...@jakarta.apache.org>