Package com.facebook.swift.codec

Examples of com.facebook.swift.codec.ThriftCodecManager

265
266
267
268
269
270
271
272
273
    @BeforeMethod(alwaysRun = true)
    public void setup()
            throws IllegalAccessException, InstantiationException, TException
    {
        codecManager = new ThriftCodecManager();
        clientManager = new ThriftClientManager(codecManager);
        syncServer = createSyncServer();
    }
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
    public void testPumaSwift()
            throws Exception
    {
        // create server and start
        PumaReadServer puma = new PumaReadServer();
        ThriftServiceProcessor processor = new ThriftServiceProcessor(new ThriftCodecManager(), puma);

        // create server and client
        try (
                ThriftServer server = new ThriftServer(processor).start();
                ThriftClientManager clientManager = new ThriftClientManager();
View Full Code Here
117
118
119
120
121
122
123
124
125
126
127
    {
        PumaReadServer puma = new PumaReadServer();
        ReadSemanticException exception = new ReadSemanticException("my exception");
        puma.setException(exception);

        TProcessor processor = new ThriftServiceProcessor(new ThriftCodecManager(), puma);
        try (
                ThriftServer server = new ThriftServer(processor).start();
                ThriftClientManager clientManager = new ThriftClientManager();
                PumaReadService pumaClient = clientManager.createClient(
                        new FramedClientConnector(HostAndPort.fromParts("localhost", server.getPort())),
View Full Code Here
246
247
248
249
250
251
252
253
254
    @BeforeMethod(alwaysRun = true)
    public void setup()
            throws IllegalAccessException, InstantiationException, TException
    {
        codecManager = new ThriftCodecManager();
        clientManager = new ThriftClientManager(codecManager);
        syncServer = createSyncServer();
    }
View Full Code Here
89
90
91
92
93
94
95
            });
    private final Set<ThriftClientEventHandler> globalEventHandlers;

    public ThriftClientManager()
    {
        this(new ThriftCodecManager());
    }
View Full Code Here
51
52
53
54
55
56
57
58
59
60
    @Test
    public void testSwiftService()
            throws Exception
    {
        SwiftScribe scribeService = new SwiftScribe();
        NiftyProcessor processor = new ThriftServiceProcessor(new ThriftCodecManager(), ImmutableList.<ThriftEventHandler>of(), scribeService);

        List<LogEntry> messages = testProcessor(processor);
        assertEquals(scribeService.getMessages(), newArrayList(concat(toSwiftLogEntry(messages), toSwiftLogEntry(messages))));
    }
View Full Code Here
72
73
74
75
76
77
78
79
    @Test(expectedExceptions = IllegalArgumentException.class, expectedExceptionsMessageRegExp = "Multiple entries with same key.*")
    public void testConflictingServices()
            throws Exception
    {
        new ThriftServiceProcessor(new ThriftCodecManager(), ImmutableList.<ThriftEventHandler>of(),
                new SwiftScribe(), new ConflictingLogService());
    }
View Full Code Here
218
219
220
221
222
223
224
225
226
227
228
    {
        SwiftScribe scribeService = new SwiftScribe();
        EventHandler eventHandler = new EventHandler(niftyProcessor);
        EventHandler secondHandler = new EventHandler(niftyProcessor);
        List<EventHandler> handlers = ImmutableList.of(eventHandler, secondHandler);
        final ThriftServiceProcessor processor = new ThriftServiceProcessor(new ThriftCodecManager(), handlers, scribeService);

        List<LogEntry> messages = niftyProcessor ?
                testProcessor(processor) : testProcessor(NiftyProcessorAdapters.processorToTProcessor(processor));
        assertEquals(scribeService.getMessages(), newArrayList(concat(toSwiftLogEntry(messages), toSwiftLogEntry(messages))));
        assertTrue(eventHandler.validate(2));
View Full Code Here
75
76
77
78
79
80
81
82
83
84
85
                new ThriftServerConfig().setWorkerThreads(200)
                                        .setPort(4567)
                                        .setTransportName("header")
                                        .setProtocolName("header");

        ThriftCodecManager codecManager = new ThriftCodecManager();

        ServiceInfo serviceInfo = new ServiceInfo("ExampleService", "1.0");

        // Fill this in to customize your service's response to
        // fb303 getOptions()
View Full Code Here
311
312
313
314
315
316
317
318
319
    @BeforeMethod(alwaysRun = true)
    public void setup()
            throws IllegalAccessException, InstantiationException, TException
    {
        codecManager = new ThriftCodecManager();
        clientManager = new ThriftClientManager(codecManager);
        syncServer = createSyncServer();
    }
View Full Code Here
TOP

Related Classes of com.facebook.swift.codec.ThriftCodecManager

  • com.facebook.swift.codec.internal.builtin.BooleanArrayThriftCodec
  • com.facebook.swift.codec.internal.builtin.BooleanThriftCodec
  • com.facebook.swift.codec.internal.builtin.ByteBufferThriftCodec
  • com.facebook.swift.codec.internal.builtin.ByteThriftCodec
  • com.facebook.swift.codec.internal.builtin.DoubleArrayThriftCodec
  • com.facebook.swift.codec.internal.builtin.DoubleThriftCodec
  • com.facebook.swift.codec.internal.builtin.IntArrayThriftCodec
  • com.facebook.swift.codec.internal.builtin.IntegerThriftCodec
  • com.facebook.swift.codec.internal.builtin.LongArrayThriftCodec
  • com.facebook.swift.codec.internal.builtin.LongThriftCodec
    • 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.