Package org.apache.jackrabbit.oak.plugins.segment.standby.server

Examples of org.apache.jackrabbit.oak.plugins.segment.standby.server.StandbyServer.start()

120
121
122
123
124
125
126
127
128
129
130
        p.flipByte(flipPosition);
        p.run();

        NodeStore store = new SegmentNodeStore(storeS);
        final StandbyServer server = new StandbyServer(port, storeS, ssl);
        server.start();
        addTestContent(store, "server");
        storeS.flush();  // this speeds up the test a little bit...

        StandbyClient cl = new StandbyClient(LOCALHOST, PROXY_PORT, storeC, ssl);
        cl.run();
View Full Code Here
48
49
50
51
52
53
54
55
56
57
58
    @Test
    public void testFailover() throws Exception {

        NodeStore store = new SegmentNodeStore(storeS);
        final StandbyServer server = new StandbyServer(port, storeS);
        server.start();
        addTestContent(store, "server");

        StandbyClient cl = new StandbyClient("127.0.0.1", port, storeC);
        cl.run();
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
    @Test
    public void testMultipleClients() throws Exception {
        NodeStore store = new SegmentNodeStore(storeS);
        final StandbyServer server = new StandbyServer(port, storeS);
        server.start();
        SegmentTestUtils.addTestContent(store, "server");
        storeS.flush();  // this speeds up the test a little bit...

        StandbyClient cl1 = new StandbyClient("127.0.0.1", port, storeC);
        StandbyClient cl2 = new StandbyClient("127.0.0.1", port, storeC2);
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
    }

    @Test
    public void testServerEmptyConfig() throws Exception {
        final StandbyServer server = new StandbyServer(this.port, this.storeS);
        server.start();

        final MBeanServer jmxServer = ManagementFactory.getPlatformMBeanServer();
        ObjectName status = new ObjectName(StandbyStatusMBean.JMX_NAME + ",id=*");
        try {
            Set<ObjectName> instances = jmxServer.queryNames(status, null);
View Full Code Here
143
144
145
146
147
148
149
150
151
152
153
    @Test
    @Ignore("OAK-2086")
    public void testClientAndServerEmptyConfig() throws Exception {
        final StandbyServer server = new StandbyServer(this.port, this.storeS);
        server.start();

        System.setProperty(StandbyClient.CLIENT_ID_PROPERTY_NAME, "Bar");
        final StandbyClient client = new StandbyClient("127.0.0.1", this.port, this.storeC);
        client.start();
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
    @Test
    public void testFailoverSecure() throws Exception {

        NodeStore store = new SegmentNodeStore(storeS);
        final StandbyServer server = new StandbyServer(port, storeS, true);
        server.start();
        addTestContent(store, "server");
        storeS.flush();  // this speeds up the test a little bit...

        StandbyClient cl = new StandbyClient("127.0.0.1", port, storeC, true);
        cl.run();
View Full Code Here
65
66
67
68
69
70
71
72
73
74
75
    @Test
    public void testFailoverSecureServerPlainClient() throws Exception {

        NodeStore store = new SegmentNodeStore(storeS);
        final StandbyServer server = new StandbyServer(port, storeS, true);
        server.start();
        addTestContent(store, "server");
        storeS.flush();  // this speeds up the test a little bit...

        StandbyClient cl = new StandbyClient("127.0.0.1", port, storeC);
        cl.run();
View Full Code Here
85
86
87
88
89
90
91
92
93
94
95
    @Test
    public void testFailoverPlainServerSecureClient() throws Exception {

        NodeStore store = new SegmentNodeStore(storeS);
        final StandbyServer server = new StandbyServer(port, storeS);
        server.start();
        addTestContent(store, "server");
        storeS.flush();  // this speeds up the test a little bit...

        StandbyClient cl = new StandbyClient("127.0.0.1", port, storeC, true);
        cl.run();
View Full Code Here
144
145
146
147
148
149
150
151
152
153
154
    }

    private void createTestWithConfig(String host, String[] ipRanges, boolean expectedToWork) throws Exception {
        NodeStore store = new SegmentNodeStore(storeS);
        final StandbyServer server = new StandbyServer(port, storeS, ipRanges);
        server.start();
        addTestContent(store, "server");
        storeS.flush();  // this speeds up the test a little bit...

        StandbyClient cl = new StandbyClient(host, port, storeC);
        cl.run();
View Full Code Here
108
109
110
111
112
113
114
115
116
117
118
        }
        store.merge(rootbuilder, EmptyHook.INSTANCE, CommitInfo.EMPTY);
        storeS.flush();

        final StandbyServer server = new StandbyServer(port, storeS, useSSL);
        server.start();

        System.setProperty(StandbyClient.CLIENT_ID_PROPERTY_NAME, "Bar");
        StandbyClient cl = new StandbyClient("127.0.0.1", port, storeC, useSSL);

        final MBeanServer jmxServer = ManagementFactory.getPlatformMBeanServer();
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.