Package org.apache.servicemix.jbi.container

Examples of org.apache.servicemix.jbi.container.JBIContainer

80
81
82
83
84
85
86
87
88
89
90
            System.err.println("Caught: " + e);
            e.printStackTrace();
        }
    }
    protected void setUp() throws Exception {
        container = new JBIContainer();
        container.setUseMBeanServer(useJmx);
        container.setCreateMBeanServer(useJmx);
        container.setMonitorInstallationDirectory(false);
        container.setNamingContext(new InitialContext());
        container.setEmbedded(true);
View Full Code Here
142
143
144
145
146
147
148
149
150
151
152
153
154
155
            container = null;
        }
    }

    private JBIContainer createContainer() throws GBeanNotFoundException {
        JBIContainer container = new JBIContainer();
        container.setName(name);
        container.setRootDir(directory);
        TransactionManager tm = getTransactionManager();
        container.setTransactionManager(tm);
        container.setMonitorInstallationDirectory(false);
        container.setMonitorDeploymentDirectory(false);
        return container;
    }
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
    private static Log logger = LogFactory.getLog(HttpConsumerTest.class);

    protected JBIContainer container;

    protected void setUp() throws Exception {
        container = new JBIContainer();
        container.setUseMBeanServer(false);
        container.setCreateMBeanServer(false);
        container.setEmbedded(true);
        container.init();
    }
View Full Code Here
102
103
104
105
106
107
108
109
110
111
112
    }

    private void startServiceMix() throws MojoExecutionException {
        try {
            getLog().info("Starting Apache ServiceMix");
            jbiContainer = new JBIContainer();
            jbiContainer.setRmiPort(Integer.parseInt(port));
            jbiContainer.setCreateMBeanServer(true);
            jbiContainer.setInstallationDirPath(installDirectory);
            jbiContainer.setDeploymentDirPath(deploymentDirectory);
            jbiContainer.setRootDir(rootDirectory);
View Full Code Here
34
35
36
37
38
39
40
41
42
43
public class ClientFactoryTest extends TestCase {

    private JBIContainer jbi;
   
    protected void setUp() throws Exception {
        jbi = new JBIContainer();
        jbi.setEmbedded(true);
        jbi.init();
        jbi.start();
    }
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
    protected JBIContainer jbi;
    protected ReceiverComponent receiver;
   
    protected void setUp() throws Exception {
        jbi = new JBIContainer();
        jbi.setUseMBeanServer(false);
        jbi.setEmbedded(true);
        List entries = new ArrayList();
        entries.add(new AuthorizationEntry(ReceiverComponent.SERVICE, null, null, "programmers"));
        AuthorizationMap map = new DefaultAuthorizationMap(entries);
View Full Code Here
58
59
60
61
62
63
64
65
66
67
68
        broker.addConnector("tcp://localhost:61616");
        broker.start();
       
        txManager = (TransactionManager) new GeronimoPlatformTransactionManager();
       
        jbi = new JBIContainer();
        jbi.setFlows(new Flow[] { new SedaFlow(), new JCAFlow() });
        jbi.setEmbedded(true);
        jbi.setUseMBeanServer(false);
        jbi.setTransactionManager(txManager);
        jbi.setAutoEnlistInTransaction(true);
View Full Code Here
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
import org.apache.servicemix.jbi.resolver.URIResolver;

public class RegistryTest extends TestCase {

    public void testResolveEPR() throws Exception {
        JBIContainer container = new JBIContainer();
        container.setEmbedded(true);
        container.init();
        container.start();
       
        EchoComponent component = new EchoComponent();
        component.setService(new QName("http://foo.bar.com", "myService"));
        container.activateComponent(component, "component");
        ServiceEndpoint ep = component.getContext().activateEndpoint(new QName("http://foo.bar.com", "myService"), "myEndpoint");
        DocumentFragment epr = ep.getAsReference(null);
        ServiceEndpoint ep2 = component.getContext().resolveEndpointReference(epr);
        assertSame(ep, ep2);
    }
View Full Code Here
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
        ServiceEndpoint ep2 = component.getContext().resolveEndpointReference(epr);
        assertSame(ep, ep2);
    }
   
    public void testResolveWSAEPR() throws Exception {
        JBIContainer container = new JBIContainer();
        container.setEmbedded(true);
        container.init();
        container.start();
       
        EchoComponent component = new EchoComponent();
        component.setService(new QName("http://foo.bar.com", "myService"));
        container.activateComponent(component, "component");
        ServiceEndpoint ep = component.getContext().activateEndpoint(new QName("http://foo.bar.com", "myService"), "myEndpoint");
        DocumentFragment epr = URIResolver.createWSAEPR("endpoint:http://foo.bar.com/myService/myEndpoint");
        ServiceEndpoint ep2 = component.getContext().resolveEndpointReference(epr);
        assertSame(ep, ep2);
    }
View Full Code Here
47
48
49
50
51
52
53
54
55
56
    private static final Log LOG = LogFactory.getLog(DeliveryChannelImplTest.class);

    protected JBIContainer container;

    protected void setUp() throws Exception {
        container = new JBIContainer();
        container.setEmbedded(true);
        container.init();
        container.start();
    }
View Full Code Here
TOP

Related Classes of org.apache.servicemix.jbi.container.JBIContainer

  • loanbroker.CreditAgencyTest
  • org.apache.cxf.systest.jbi.ClientServerTest
  • org.apache.ode.jbi.OdeJbiComponentLifeCycleTest
  • org.apache.servicemix.bean.ConsumerBeanTest
  • org.apache.servicemix.bean.ConsumerListenerTest
  • org.apache.servicemix.bpe.BPEComponentTest
  • org.apache.servicemix.client.ClientFactoryTest
  • org.apache.servicemix.client.RemoteServiceMixClient
  • org.apache.servicemix.client.SimpleClientTest
  • org.apache.servicemix.common.TransactionsTest
    • 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.