2
* JBoss, Home of Professional Open Source
4
* Distributable under LGPL license.
5
* See terms of license at gnu.org.
7
package org.jboss.test.remoting.transport.socket.serverlockup;
9
import org.jboss.remoting.transport.socket.MicroSocketClientInvoker;
10
import org.jboss.remoting.InvokerLocator;
11
import org.jboss.logging.Logger;
13
import java.net.Socket;
16
* @author <a href="mailto:ovidiu@jboss.org">Ovidiu Feodorov</a>
17
* @version <tt>$Revision: 1972 $</tt>
19
* $Id: RogueClientInvoker.java 1972 2007-01-23 09:39:03Z ovidiu $
21
public class RogueClientInvoker extends MicroSocketClientInvoker
23
// Constants ------------------------------------------------------------------------------------
25
private static final Logger log = Logger.getLogger(RogueClientInvoker.class);
27
// Static ---------------------------------------------------------------------------------------
29
// Attributes -----------------------------------------------------------------------------------
31
// Constructors ---------------------------------------------------------------------------------
33
public RogueClientInvoker(InvokerLocator locator)
38
// Public ---------------------------------------------------------------------------------------
40
public String toString()
42
return "RogueClientInvoker[" + Integer.toHexString(hashCode()) + "]";
45
// Package protected ----------------------------------------------------------------------------
47
void openConnectionButDontSendAnything() throws Exception
49
log.debug(this + " creating simple socket");
51
Socket socket = new Socket(locator.getHost(), locator.getPort());
53
log.debug(this + " created socket " + socket + ", sleeping ...");
57
log.debug(this + " done sleeping");
61
// OutputStream outputStream = socketWrapper.getOutputStream();
63
// writeVersion(outputStream, version);
65
// versionedWrite(outputStream, marshaller, invocation, version);
67
// InputStream inputStream = socketWrapper.getInputStream();
69
// version = readVersion(inputStream);
71
// response = versionedRead(inputStream, unmarshaller, version);
74
// Protected ------------------------------------------------------------------------------------
76
// Private --------------------------------------------------------------------------------------
78
// Inner classes --------------------------------------------------------------------------------