Examples of org.apache.cxf.transport.jms.AddressType

org.apache.cxf.transport.jms.AddressType
as.xmlsoap.org/wsdl/}tExtensibilityElement"> <sequence> <element name="JMSNamingProperty" type="{http://cxf.apache.org/transports/jms}JMSNamingPropertyType" maxOccurs="unbounded" minOccurs="0"/> </sequence> <attribute name="destinationStyle" type="{http://cxf.apache.org/transports/jms}DestinationStyleType" default="queue" /> <attribute name="jndiConnectionFactoryName" use="required" type="{http://www.w3.org/2001/XMLSchema}string" /> <attribute name="jndiDestinationName" type="{http://www.w3.org/2001/XMLSchema}string" /> <attribute name="jmsDestinationName" type="{http://www.w3.org/2001/XMLSchema}string" /> <attribute name="jndiReplyDestinationName" type="{http://www.w3.org/2001/XMLSchema}string" /> <attribute name="jmsReplyDestinationName" type="{http://www.w3.org/2001/XMLSchema}string" /> <attribute name="jndiReplyToDestinationName" type="{http://www.w3.org/2001/XMLSchema}string" /> <attribute name="jmsReplyToDestinationName" type="{http://www.w3.org/2001/XMLSchema}string" /> <attribute name="connectionUserName" type="{http://www.w3.org/2001/XMLSchema}string" /> <attribute name="connectionPassword" type="{http://www.w3.org/2001/XMLSchema}string" /> <attribute name="useJms11" type="{http://cxf.apache.org/configuration/parameterized-types}ParameterizedBoolean" /> <attribute name="reconnectOnException" type="{http://cxf.apache.org/configuration/parameterized-types}ParameterizedBoolean" /> </extension> </complexContent> </complexType>

            }
            boolean found = false;
            while (it.hasNext()) {
                Object obj = it.next();
                if (obj instanceof AddressType) {
                    AddressType jmsAddress = (AddressType)obj;
                    if (!(jmsAddress.getDestinationStyle() != null
                          && "queue".equalsIgnoreCase(jmsAddress.getDestinationStyle().toString()))) {
                        break;
                    }
                    if (!(jmsAddress.getJndiDestinationName() != null && jmsAddress.getJndiDestinationName()
                        .equals("dynamicQueues/test.cxf.jmstransport.queue"))) {
                        break;
                    }


                    assertEquals(2, jmsAddress.getJMSNamingProperty().size());
                    assertEquals("java.naming.factory.initial",
                                 jmsAddress.getJMSNamingProperty().get(0).getName());
                    assertEquals("tcp://localhost:91919",
                                 jmsAddress.getJMSNamingProperty().get(1).getValue());


                    found = true;
                    break;
                }
            }

View Full Code Here

            }
            boolean found = false;
            while (it.hasNext()) {
                Object obj = it.next();
                if (obj instanceof AddressType) {
                    AddressType jmsAddress = (AddressType)obj;
                    if (!(jmsAddress.getDestinationStyle() != null
                          && "queue".equalsIgnoreCase(jmsAddress.getDestinationStyle().toString()))) {
                        break;
                    }
                    if (!(jmsAddress.getJndiDestinationName() != null && jmsAddress.getJndiDestinationName()
                        .equals("dynamicQueues/test.cxf.jmstransport.queue"))) {
                        break;
                    }


                    assertEquals(2, jmsAddress.getJMSNamingProperty().size());
                    assertEquals("java.naming.factory.initial",
                                 jmsAddress.getJMSNamingProperty().get(0).getName());
                    assertEquals("tcp://localhost:61616",
                                 jmsAddress.getJMSNamingProperty().get(1).getValue());


                    found = true;
                    break;
                }
            }

View Full Code Here

            Client client = ClientProxy.getClient(greeter);
            client.getEndpoint().getOutInterceptors().add(new TibcoSoapActionInterceptor());
            client.getOutInterceptors().add(new LoggingOutInterceptor());
            client.getInInterceptors().add(new LoggingInInterceptor());
            EndpointInfo ei = client.getEndpoint().getEndpointInfo();
            AddressType address = ei.getTraversedExtensor(new AddressType(), AddressType.class);
            JMSNamingPropertyType name = new JMSNamingPropertyType();
            JMSNamingPropertyType password = new JMSNamingPropertyType();
            name.setName("java.naming.security.principal");
            name.setValue("ivan");
            password.setName("java.naming.security.credentials");
            password.setValue("the-terrible");
            address.getJMSNamingProperty().add(name);
            address.getJMSNamingProperty().add(password);
            for (int idx = 0; idx < 5; idx++) {


                greeter.greetMeOneWay("test String");
                
                String greeting = greeter.greetMe("Milestone-" + idx);

View Full Code Here

            }
            boolean found = false;
            while (it.hasNext()) {
                Object obj = it.next();
                if (obj instanceof AddressType) {
                    AddressType jmsAddress = (AddressType)obj;
                    if (!(jmsAddress.getDestinationStyle() != null
                          && "queue".equalsIgnoreCase(jmsAddress.getDestinationStyle().toString()))) {
                        break;
                    }
//                     if (!(jmsAddress.getDurableSubscriberName() != null && jmsAddress
//                         .getDurableSubscriberName().equals("cxf_Queue_subscriber"))) {
//                         break;
//                     }
//                     if (!(jmsAddress.getInitialContextFactory() != null && jmsAddress
//                         .getInitialContextFactory()
//                         .equals("org.activemq.jndi.ActiveMQInitialContextFactory"))) {
//                         break;
//                     }
                    if (!(jmsAddress.getJndiDestinationName() != null && jmsAddress.getJndiDestinationName()
                        .equals("dynamicQueues/test.cxf.jmstransport.queue"))) {
                        System.err.println("jms address break 2");
                        break;
                    }
//                 if (!(jmsAddress.getJndiProviderURL() != null && jmsAddress.getJndiProviderURL()

View Full Code Here

                soapAddress.setLocationURI(HTTP_PREFIX + "/" + env.get(ToolConstants.CFG_SERVICE) + "/"
                                           + env.get(ToolConstants.CFG_PORT));
            }
            port.addExtensibilityElement(soapAddress);
        } else if ("jms".equalsIgnoreCase((String)env.get(ToolConstants.CFG_TRANSPORT))) {
            AddressType jmsAddress = null;
            //JMSAddress jmsAddress = null;
            //JMSAddressSerializer jmsAddressSerializer = new JMSAddressSerializer();
            try {
//extReg.registerSerializer(JMSAddress.class, ToolConstants.JMS_ADDRESS, jmsAddressSerializer);
//extReg.registerDeserializer(JMSAddress.class, ToolConstants.JMS_ADDRESS, jmsAddressSerializer);
                jmsAddress = (AddressType)extReg.createExtension(Port.class, ToolConstants.JMS_ADDRESS);
                if (env.optionSet(ToolConstants.JMS_ADDR_DEST_STYLE)) {
                    //jmsAddress.setDestinationStyle((String)env.get(ToolConstants.JMS_ADDR_DEST_STYLE));
                }
                if (env.optionSet(ToolConstants.JMS_ADDR_INIT_CTX)) {
                    //jmsAddress.setInitialContextFactory((String)env.get(ToolConstants.JMS_ADDR_INIT_CTX));
                }
                if (env.optionSet(ToolConstants.JMS_ADDR_JNDI_DEST)) {
                    jmsAddress.setJndiDestinationName((String)env.get(ToolConstants.JMS_ADDR_JNDI_DEST));
                }
                if (env.optionSet(ToolConstants.JMS_ADDR_JNDI_FAC)) {
                    jmsAddress.setJndiConnectionFactoryName((String)env.get(ToolConstants.JMS_ADDR_JNDI_FAC));
                }
                if (env.optionSet(ToolConstants.JMS_ADDR_JNDI_URL)) {
                    //jmsAddress.setJndiProviderURL((String)env.get(ToolConstants.JMS_ADDR_JNDI_URL));
                }
                if (env.optionSet(ToolConstants.JMS_ADDR_MSGID_TO_CORRID)) {

View Full Code Here

            Greeter greeter = service.getPort(portName, Greeter.class);
            
            Client client = ClientProxy.getClient(greeter);
            client.getEndpoint().getOutInterceptors().add(new TibcoSoapActionInterceptor());
            EndpointInfo ei = client.getEndpoint().getEndpointInfo();
            AddressType address = ei.getTraversedExtensor(new AddressType(), AddressType.class);
            JMSNamingPropertyType name = new JMSNamingPropertyType();
            JMSNamingPropertyType password = new JMSNamingPropertyType();
            name.setName("java.naming.security.principal");
            name.setValue("ivan");
            password.setName("java.naming.security.credentials");
            password.setValue("the-terrible");
            address.getJMSNamingProperty().add(name);
            address.getJMSNamingProperty().add(password);
            for (int idx = 0; idx < 5; idx++) {


                greeter.greetMeOneWay("test String");
                
                String greeting = greeter.greetMe("Milestone-" + idx);

View Full Code Here

        try {
            Greeter greeter = service.getPort(portName, Greeter.class);
            
            Client client = ClientProxy.getClient(greeter);
            EndpointInfo ei = client.getEndpoint().getEndpointInfo();
            AddressType address = ei.getTraversedExtensor(new AddressType(), AddressType.class);
            JMSNamingPropertyType name = new JMSNamingPropertyType();
            JMSNamingPropertyType password = new JMSNamingPropertyType();
            name.setName("java.naming.security.principal");
            name.setValue("ivan");
            password.setName("java.naming.security.credentials");
            password.setValue("the-terrible");
            address.getJMSNamingProperty().add(name);
            address.getJMSNamingProperty().add(password);
            for (int idx = 0; idx < 5; idx++) {


                greeter.greetMeOneWay("test String");


                String greeting = greeter.greetMe("Milestone-" + idx);

View Full Code Here

            Client client = ClientProxy.getClient(greeter);
            client.getEndpoint().getOutInterceptors().add(new TibcoSoapActionInterceptor());
            client.getOutInterceptors().add(new LoggingOutInterceptor());
            client.getInInterceptors().add(new LoggingInInterceptor());
            EndpointInfo ei = client.getEndpoint().getEndpointInfo();
            AddressType address = ei.getTraversedExtensor(new AddressType(), AddressType.class);
            JMSNamingPropertyType name = new JMSNamingPropertyType();
            JMSNamingPropertyType password = new JMSNamingPropertyType();
            name.setName("java.naming.security.principal");
            name.setValue("ivan");
            password.setName("java.naming.security.credentials");
            password.setValue("the-terrible");
            address.getJMSNamingProperty().add(name);
            address.getJMSNamingProperty().add(password);
            for (int idx = 0; idx < 5; idx++) {


                greeter.greetMeOneWay("test String");
                
                String greeting = greeter.greetMe("Milestone-" + idx);

View Full Code Here

            Client client = ClientProxy.getClient(greeter);
            client.getEndpoint().getOutInterceptors().add(new TibcoSoapActionInterceptor());
            client.getOutInterceptors().add(new LoggingOutInterceptor());
            client.getInInterceptors().add(new LoggingInInterceptor());
            EndpointInfo ei = client.getEndpoint().getEndpointInfo();
            AddressType address = ei.getTraversedExtensor(new AddressType(), AddressType.class);
            JMSNamingPropertyType name = new JMSNamingPropertyType();
            JMSNamingPropertyType password = new JMSNamingPropertyType();
            name.setName("java.naming.security.principal");
            name.setValue("ivan");
            password.setName("java.naming.security.credentials");
            password.setValue("the-terrible");
            address.getJMSNamingProperty().add(name);
            address.getJMSNamingProperty().add(password);
            for (int idx = 0; idx < 5; idx++) {


                greeter.greetMeOneWay("test String");
                
                String greeting = greeter.greetMe("Milestone-" + idx);

View Full Code Here

        try {
            Greeter greeter = service.getPort(portName, Greeter.class);
            
            Client client = ClientProxy.getClient(greeter);
            EndpointInfo ei = client.getEndpoint().getEndpointInfo();
            AddressType address = ei.getTraversedExtensor(new AddressType(), AddressType.class);
            JMSNamingPropertyType name = new JMSNamingPropertyType();
            JMSNamingPropertyType password = new JMSNamingPropertyType();
            name.setName("java.naming.security.principal");
            name.setValue("ivan");
            password.setName("java.naming.security.credentials");
            password.setValue("the-terrible");
            address.getJMSNamingProperty().add(name);
            address.getJMSNamingProperty().add(password);
            for (int idx = 0; idx < 5; idx++) {


                greeter.greetMeOneWay("test String");


                String greeting = greeter.greetMe("Milestone-" + idx);

View Full Code Here

0 1 2 3 4 5 6

TOP

Related Classes of org.apache.cxf.transport.jms.AddressType

org.apache.cxf.systest.jms.JMSClientServerGzipTest

org.apache.cxf.systest.jms.JMSClientServerSoap12Test

org.apache.cxf.systest.jms.JMSClientServerTest

org.apache.cxf.tools.misc.processor.WSDLToServiceProcessor

org.apache.cxf.tools.misc.processor.WSDLToServiceProcessorTest

org.apache.cxf.transport.jms.wsdl11.JmsTransportPlugin

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.