import org.jboss.remoting3.*; import org.jboss.remoting3.callback.*; public class AsyncCommunicationExample { public static void main(String[] args) throws Exception { Configuration configuration = new Configuration(); Connection connection = ConnectionFactory.createConnection(configuration); Endpoint endpoint = EndpointFactory.createEndpoint(connection); CallbackHandler callbackHandler = new SimpleCallbackHandler() { @Override public void onComplete(Object result) { } @Override public void onThrowable(Throwable throwable) { } }; InvocationRequest invocationRequest = endpoint.createInvocationRequest(); invocationRequest.setMethodName("sayHello"); invocationRequest.setTargetObject("World"); invocationRequest.registerCallback(callbackHandler); invocationRequest.execute(); Thread.sleep(1000); connection.close(); } } <configuration> <connector name="remoting-connector" connectorClassName="org.jboss.remoting3.RemotingConnector" module="org.jboss.remoting3"> <param name="protocol">http-remoting</param> <param name="host">localhost</param> <param name="port">8080</param> </connector> <endpoint name="remoting-endpoint" outbound="true"> <param name="connector">remoting-connector</param> </endpoint> </configuration>


上一篇:
下一篇:
切换中文