Examples of JMSBinding

Examples of org.apache.camel.component.jms.JmsBinding

36
37
38
39
40
41
42
43
44
45
46
        endpoint.expectedBodiesReceived("Completed");
       
        Map<String, Object> headers = new HashMap<String, Object>();
        headers.put("foo", "bar");
        // this header should not be sent as its value cannot be serialized
        headers.put("binding", new JmsBinding());

        template.sendBodyAndHeaders("activemq:Test.BindingQueue", "SomeBody", headers);

        // lets wait for the method to be invoked
        assertMockEndpointsSatisfied();
View Full Code Here

Examples of org.apache.camel.component.jms.JmsBinding

36
37
38
39
40
41
42
43
44
45
46
        endpoint.expectedBodiesReceived("Completed");
       
        Map<String, Object> headers = new HashMap<String, Object>();
        headers.put("foo", "bar");
        // this header should not be sent as its value cannot be serialized
        headers.put("binding", new JmsBinding());

        template.sendBodyAndHeaders("activemq:Test.BindingQueue", "SomeBody", headers);

        // lets wait for the method to be invoked
        assertMockEndpointsSatisfied();
View Full Code Here

Examples of org.apache.camel.component.jms.JmsBinding

36
37
38
39
40
41
42
43
44
45
46
        endpoint.expectedBodiesReceived("Completed");
       
        Map<String, Object> headers = new HashMap<String, Object>();
        headers.put("foo", "bar");
        // this header should not be sent as its value cannot be serialized
        headers.put("binding", new JmsBinding());

        template.sendBodyAndHeaders("activemq:Test.BindingQueue", "SomeBody", headers);

        // lets wait for the method to be invoked
        assertMockEndpointsSatisfied();
View Full Code Here

Examples of org.apache.camel.component.jms.JmsBinding

36
37
38
39
40
41
42
43
44
45
46
        endpoint.expectedBodiesReceived("Completed");
       
        Map<String, Object> headers = new HashMap<String, Object>();
        headers.put("foo", "bar");
        // this header should not be sent as its value cannot be serialized
        headers.put("binding", new JmsBinding());

        template.sendBodyAndHeaders("activemq:Test.BindingQueue", "SomeBody", headers);

        // lets wait for the method to be invoked
        assertMockEndpointsSatisfied();
View Full Code Here

Examples of org.apache.tuscany.sca.binding.jms.JMSBinding

62
63
64
65
66
67
68
69
70
        JMSResourceFactory jmsRF = jmsRFEP.createJMSResourceFactory((JMSBinding)endpointReference.getBinding());
        return new JMSBindingReferenceBindingProvider(endpointReference, extensionPoints, jmsRF);
    }

    public ServiceBindingProvider createServiceBindingProvider(RuntimeEndpoint endpoint) {
        JMSBinding binding = (JMSBinding)endpoint.getBinding();
        JMSResourceFactory jmsRF = jmsRFEP.createJMSResourceFactory(binding);
        return new JMSBindingServiceBindingProvider(extensionPoints, endpoint, serviceListenerFactory, extensionPoints, jmsRF);
    }
View Full Code Here

Examples of org.apache.tuscany.sca.binding.jms.JMSBinding

86
87
88
89
90
91
92
93
94
95
96
97
               
                if (callbackdestName != null) {
                  List<EndpointReference> refs = endpoint.getCallbackEndpointReferences();
                  for (EndpointReference ref : refs ) {
                    if  (ref.getBinding() instanceof JMSBinding ) {
                      JMSBinding callbackBinding = (JMSBinding) ref.getBinding();
                      callbackBinding.setDestinationName(callbackdestName);
                    }
                  }
               } 

                String callbackID = jmsMsg.getStringProperty(JMSBindingConstants.CALLBACK_ID_PROPERTY);
View Full Code Here

Examples of org.apache.tuscany.sca.binding.jms.JMSBinding

70
71
72
73
74
75
76
77
78
79
80
        Assert.assertNotNull(jsonpBinding);
   
        Service jmsService = composite.getService("JMSService");
        Assert.assertNotNull(jmsService);
        Assert.assertEquals(1, jmsService.getBindings().size());
        JMSBinding jmsBinding = jmsService.getBinding(JMSBinding.class);
        Assert.assertNotNull(jmsBinding);

        Service rmiService = composite.getService("RMIService");
        Assert.assertNotNull(rmiService);
        Assert.assertEquals(1, rmiService.getBindings().size());
View Full Code Here

Examples of org.apache.tuscany.sca.binding.jms.JMSBinding

62
63
64
65
66
67
68
69
70
        JMSResourceFactory jmsRF = jmsRFEP.createJMSResourceFactory((JMSBinding)endpointReference.getBinding());
        return new JMSBindingReferenceBindingProvider(endpointReference, extensionPoints, jmsRF);
    }

    public ServiceBindingProvider createServiceBindingProvider(RuntimeEndpoint endpoint) {
        JMSBinding binding = (JMSBinding)endpoint.getBinding();
        JMSResourceFactory jmsRF = jmsRFEP.createJMSResourceFactory(binding);
        return new JMSBindingServiceBindingProvider(extensionPoints, endpoint, serviceListenerFactory, extensionPoints, jmsRF);
    }
View Full Code Here

Examples of org.apache.tuscany.sca.binding.jms.JMSBinding

62
63
64
65
66
67
68
69
70
        JMSResourceFactory jmsRF = jmsRFEP.createJMSResourceFactory((JMSBinding)endpointReference.getBinding());
        return new JMSBindingReferenceBindingProvider(endpointReference, extensionPoints, jmsRF);
    }

    public ServiceBindingProvider createServiceBindingProvider(RuntimeEndpoint endpoint) {
        JMSBinding binding = (JMSBinding)endpoint.getBinding();
        JMSResourceFactory jmsRF = jmsRFEP.createJMSResourceFactory(binding);
        return new JMSBindingServiceBindingProvider(extensionPoints, endpoint, serviceListenerFactory, extensionPoints, jmsRF);
    }
View Full Code Here

Examples of org.apache.tuscany.sca.binding.jms.JMSBinding

100
101
102
103
104
105
106
107
108
109
110
111
            // Place the Callback destination name into the Callback EPRs for the service endpoint
            if (callbackdestName != null) {
              List<EndpointReference> refs = endpoint.getCallbackEndpointReferences();
              for (EndpointReference ref : refs ) {
                if  (ref.getBinding() instanceof JMSBinding ) {
                  JMSBinding callbackBinding = (JMSBinding) ref.getBinding();
                  callbackBinding.setDestinationName(callbackdestName);
                } // end if
              } // end for
            } // end if 

// Callback ID not used at present           
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.