Package org.apache.geronimo.remoting

Examples of org.apache.geronimo.remoting.MarshalledObject

80
81
82
83
84
85
86
87
        TransportLoader bean = (TransportLoader) MBeanProxyFactory.getProxy(TransportLoader.class, kernel.getMBeanServer(), asyncTransport);
        connectURI = bean.getClientConnectURI();

        // simulate remote copy of handle
        MarshalledObject mo = new BytesMarshalledObject(RemoteMBeanServerFactory.create(connectURI.getHost(), connectURI.getPort()));
        remoteProxy = (MBeanServer)mo.get();
    }
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
99
    }

    public void testRequestMessage() throws Exception {
        String text = "Hello World";
       
        MarshalledObject object = client.createMarshalledObject();
        object.set(text);
        Msg msg = client.createMsg();
        msg.pushMarshaledObject(object);
       
        Msg response = client.sendRequest(connectURI,msg);
        Object rc = response.popMarshaledObject().get();
View Full Code Here
105
106
107
108
109
110
111
112
113
114
115
116
    public void testDatagramMessage() throws Exception {

        String text = "Hello World";
       
        MarshalledObject object = client.createMarshalledObject();
        object.set(text);
        Msg msg = client.createMsg();
        msg.pushMarshaledObject(object);
       
        client.sendDatagram(connectURI,msg);       
        assertTrue(mockRouter.datagramCounter.attempt(10000));
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
112
                 * @see java.lang.Thread#run()
                 */
                public void run() {
                    try {
                        String text = "Hello World";
                        MarshalledObject object = client.createMarshalledObject();
                        object.set(text);
                        Msg msg = client.createMsg();
                        msg.pushMarshaledObject(object);
                               
                        barrier.barrier();
                       
View Full Code Here
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
        this.remoteURI = remoteURI;
    }

    public InvocationResult invoke(Invocation invocation) throws Throwable {

        MarshalledObject mo = InvocationSupport.getMarshaledValue(invocation);
        // URI remoteURI = InvocationSupport.getRemoteURI(invocation);
        InvocationType type = InvocationSupport.getInvocationType(invocation);
        if (type == null)
            type = InvocationType.REQUEST;

        Msg msg = transportClient.createMsg();
        msg.pushMarshaledObject(mo);
        if (type == InvocationType.REQUEST) {
            msg = transportClient.sendRequest(remoteURI, msg);
            return new SimpleInvocationResult(true, msg.popMarshaledObject());
        } else {
            transportClient.sendDatagram(remoteURI, msg);
            MarshalledObject rcmo = transportClient.createMarshalledObject();
            rcmo.set(null);
            return new SimpleInvocationResult(true, rcmo);
        }
    }
View Full Code Here
79
80
81
82
83
84
85
86
        TransportLoader bean = (TransportLoader) MBeanProxyFactory.getProxy(TransportLoader.class, kernel.getMBeanServer(), asyncTransport);
        connectURI = bean.getClientConnectURI();

        // simulate remote copy of handle
        MarshalledObject mo = new BytesMarshalledObject(RemoteMBeanServerFactory.create(connectURI.getHost(), connectURI.getPort()));
        remoteProxy = (MBeanServer)mo.get();
    }
View Full Code Here
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
        this.remoteURI = remoteURI;
    }

    public InvocationResult invoke(Invocation invocation) throws Throwable {

        MarshalledObject mo = InvocationSupport.getMarshaledValue(invocation);
        // URI remoteURI = InvocationSupport.getRemoteURI(invocation);
        InvocationType type = InvocationSupport.getInvocationType(invocation);
        if (type == null)
            type = InvocationType.REQUEST;

        Msg msg = transportClient.createMsg();
        msg.pushMarshaledObject(mo);
        if (type == InvocationType.REQUEST) {
            msg = transportClient.sendRequest(remoteURI, msg);
            return new SimpleInvocationResult(true, msg.popMarshaledObject());
        } else {
            transportClient.sendDatagram(remoteURI, msg);
            MarshalledObject rcmo = transportClient.createMarshalledObject();
            rcmo.set(null);
            return new SimpleInvocationResult(true, rcmo);
        }
    }
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
99
    }

    public void testRequestMessage() throws Exception {
        String text = "Hello World";
       
        MarshalledObject object = client.createMarshalledObject();
        object.set(text);
        Msg msg = client.createMsg();
        msg.pushMarshaledObject(object);
       
        Msg response = client.sendRequest(connectURI,msg);
        Object rc = response.popMarshaledObject().get();
View Full Code Here
105
106
107
108
109
110
111
112
113
114
115
116
    public void testDatagramMessage() throws Exception {

        String text = "Hello World";
       
        MarshalledObject object = client.createMarshalledObject();
        object.set(text);
        Msg msg = client.createMsg();
        msg.pushMarshaledObject(object);
       
        client.sendDatagram(connectURI,msg);       
        assertTrue(mockRouter.datagramCounter.attempt(10000));
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
112
                 * @see java.lang.Thread#run()
                 */
                public void run() {
                    try {
                        String text = "Hello World";
                        MarshalledObject object = client.createMarshalledObject();
                        object.set(text);
                        Msg msg = client.createMsg();
                        msg.pushMarshaledObject(object);
                               
                        barrier.barrier();
                       
View Full Code Here
TOP

Related Classes of org.apache.geronimo.remoting.MarshalledObject

  • org.apache.geronimo.remoting.JMXRemotingTest
  • org.apache.geronimo.remoting.transport.AsyncTransportStress
  • org.apache.geronimo.remoting.transport.AsyncTransportTest
  • org.apache.geronimo.remoting.transport.RemoteTransportInterceptor
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.