Examples of shutdown()

Examples of com.taobao.metamorphosis.client.MetaMessageSessionFactory.shutdown()

22
23
24
25
26
27
28
29
            Message msg = it.next();
            System.out.println("message body:" + new String(msg.getData()));
        }

        browser.shutdown();
        sessionFactory.shutdown();
    }
}
View Full Code Here

Examples of com.taobao.metamorphosis.client.TopicBrowser.shutdown()

21
22
23
24
25
26
27
28
29
        while (it.hasNext()) {
            Message msg = it.next();
            System.out.println("message body:" + new String(msg.getData()));
        }

        browser.shutdown();
        sessionFactory.shutdown();
    }
}
View Full Code Here

Examples of com.taobao.metamorphosis.client.consumer.MessageConsumer.shutdown()

251
252
253
254
255
256
257
258
259
260
        final ConsumerConfig consumerConfig = new ConsumerConfig();
        consumerConfig.setGroup("test");
        final MessageConsumer messageConsumer = this.messageSessionFactory.createConsumer(consumerConfig);
        assertNotNull(messageConsumer);
        assertTrue(this.messageSessionFactory.getChildren().contains(messageConsumer));
        messageConsumer.shutdown();
        assertFalse(this.messageSessionFactory.getChildren().contains(messageConsumer));
    }

}
View Full Code Here

Examples of com.taobao.metamorphosis.client.producer.MessageProducer.shutdown()

165
166
167
168
169
170
171
172
173
174
175
        final MessageProducer producer = this.messageSessionFactory.createProducer();
        assertNotNull(producer);
        assertTrue(producer.getPartitionSelector() instanceof RoundRobinPartitionSelector);
        assertFalse(producer.isOrdered());
        assertTrue(this.messageSessionFactory.getChildren().contains(producer));
        producer.shutdown();
        assertFalse(this.messageSessionFactory.getChildren().contains(producer));
    }


    @Ignore
View Full Code Here

Examples of com.taobao.tdhs.client.TDHSClient.shutdown()

134
135
136
137
138
139
140
141
142
143
144
        } finally {
            lock.unlock();
        }
        if (client != null) {
            logger.debug("closeConnection and shutDown TDHSClient!");
            client.shutdown();
        }
    }


    private static class ClientValue {
View Full Code Here

Examples of com.taobao.tdhs.client.TDHSClientImpl.shutdown()

28
29
30
31
32
33
34
35
            for (String v : fd) {
                System.out.print(v + " ");
            }
            System.out.print("\n");
        }
        client.shutdown();
    }
}
View Full Code Here

Examples of com.taskadapter.redmineapi.internal.comm.ConnectionEvictor.shutdown()

244
245
246
247
248
249
250
251
252
253
254
                        @Override
                        public void run() {
                            try {
                                connectionManager.shutdown();
                            } finally {
                                evictor.shutdown();
                            }
                        }
                    });
        } catch (RuntimeException t) {
            /* A little paranoia, StackOferflow, OOM, other excetpions. */
 
View Full Code Here

Examples of com.thinkaurelius.titan.core.TitanGraph.shutdown()

126
127
128
129
130
131
132
133
134
135
136
        TitanGraph graph = TitanFactory.open(c);
        new GraphGenerator(s).generateTypesAndData(graph);
        OutputStream out = new GZIPOutputStream(new FileOutputStream(o));
        GraphGenerator.writeData(graph, out);
        out.close();
        graph.shutdown();
        System.exit(0);
    }

    private final VertexAnnotator vertexAnnotator = new VertexAnnotator() {
View Full Code Here

Examples of com.thinkaurelius.titan.graphdb.blueprints.TitanBlueprintsGraph.shutdown()

27
28
29
30
31
32
33
34
35
36
        graph.makeKey("blah").dataType(Float.class).make();
        graph.makeKey("bloop").dataType(Integer.class).make();


        graph.commit();
        graph.shutdown();
        super.testCompetingThreads();
    }

}
View Full Code Here

Examples of com.tinkerpop.blueprints.Graph.shutdown()

51
52
53
54
55
56
57
58
59
60
61
    Assert.assertEquals(0, count(v2.getEdges(v1, Direction.IN, "aaa")));
    Assert.assertEquals(1, count(v2.getEdges(v1, Direction.IN, "targets")));
    Assert.assertEquals(0, count(v2.getEdges(v1, Direction.IN, "bbb")));
    Assert.assertEquals(1, count(v2.getEdges(v1, Direction.IN)));

    graph.shutdown();
  }

  @Test
  public void testComplexMapProperty() throws Exception {
    // complex map properties have problems when unmarshalled from disk to
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.