Examples of GELFMessage

Examples of org.graylog2.gelfclient.GelfMessage

34
35
36
37
38
39
40
41
42
43
44
@Test
public class GelfOutputTest {
    public void testWrite() throws Exception {
        final GelfTransport transport = mock(GelfTransport.class);
        final Message message = mock(Message.class);
        final GelfMessage gelfMessage = new GelfMessage("Test");

        final GelfOutput gelfOutput = Mockito.spy(new GelfOutput());
        doReturn(transport).when(gelfOutput).buildTransport(any(Configuration.class));
        doReturn(gelfMessage).when(gelfOutput).toGELFMessage(message);
View Full Code Here

Examples of org.graylog2.inputs.codecs.gelf.GELFMessage

33
34
35
36
37
38
39
40
    public void testGetGELFTypeDetectsZLIBCompressedMessage() throws Exception {
        byte[] fakeData = new byte[20];
        fakeData[0] = (byte) 0x78;
        fakeData[1] = (byte) 0x9c;

        GELFMessage msg = new GELFMessage(fakeData);
        assertEquals(GELFMessage.Type.ZLIB, msg.getGELFType());
    }
View Full Code Here

Examples of org.graylog2.inputs.codecs.gelf.GELFMessage

43
44
45
46
47
48
49
50
    public void testGetGELFTypeDetectsGZIPCompressedMessage() throws Exception {
        byte[] fakeData = new byte[20];
        fakeData[0] = (byte) 0x1f;
        fakeData[1] = (byte) 0x8b;

        GELFMessage msg = new GELFMessage(fakeData);
        assertEquals(GELFMessage.Type.GZIP, msg.getGELFType());
    }
View Full Code Here

Examples of org.graylog2.inputs.codecs.gelf.GELFMessage

53
54
55
56
57
58
59
60
    public void testGetGELFTypeDetectsChunkedMessage() throws Exception {
        byte[] fakeData = new byte[20];
        fakeData[0] = (byte) 0x1e;
        fakeData[1] = (byte) 0x0f;

        GELFMessage msg = new GELFMessage(fakeData);
        assertEquals(GELFMessage.Type.CHUNKED, msg.getGELFType());
    }
View Full Code Here

Examples of org.graylog2.inputs.codecs.gelf.GELFMessage

63
64
65
66
67
68
69
70
    public void testGetGELFTypeDetectsUncompressedMessage() throws Exception {
        byte[] fakeData = new byte[20];
        fakeData[0] = (byte) '{';
        fakeData[1] = (byte) '\n';

        GELFMessage msg = new GELFMessage(fakeData);
        assertEquals(GELFMessage.Type.UNCOMPRESSED, msg.getGELFType());
    }
View Full Code Here

Examples of org.graylog2.inputs.codecs.gelf.GELFMessage

69
70
71
72
73
74
75
76
        assertEquals(GELFMessage.Type.UNCOMPRESSED, msg.getGELFType());
    }

    @Test
    public void testGetJSONFromZLIBCompressedMessage() throws Exception {
        GELFMessage msg = new GELFMessage(TestHelper.zlibCompress(GELF_JSON));
        assertEquals(GELF_JSON, msg.getJSON());
    }
View Full Code Here

Examples of org.graylog2.inputs.codecs.gelf.GELFMessage

75
76
77
78
79
80
81
82
        assertEquals(GELF_JSON, msg.getJSON());
    }

    @Test
    public void testGetJSONFromGZIPCompressedMessage() throws Exception {
        GELFMessage msg = new GELFMessage(TestHelper.gzipCompress(GELF_JSON));
        assertEquals(GELF_JSON, msg.getJSON());
    }
View Full Code Here

Examples of org.graylog2.inputs.codecs.gelf.GELFMessage

83
84
85
86
87
88
89
90
    @Test
    public void testGetJSONFromUncompressedMessage() throws Exception {
        byte[] text = GELF_JSON.getBytes("UTF-8");

        GELFMessage msg = new GELFMessage(text);
        assertEquals(GELF_JSON, msg.getJSON());
    }
View Full Code Here

Examples of org.graylog2.inputs.codecs.gelf.GELFMessage

94
95
96
97
98
99
100
101
102
103
104
        String id = "foobar01";
        int seqNum = 1;
        int seqCnt = 5;
        byte[] data = TestHelper.gzipCompress(GELF_JSON);

        GELFMessage msg = new GELFMessage(TestHelper.buildGELFMessageChunk(id, seqNum, seqCnt, data));
        GELFMessageChunk chunk = new GELFMessageChunk(msg, null);
       
        assertEquals(TestHelper.toHex(id), chunk.getId());
        assertEquals(seqNum, chunk.getSequenceNumber());
        assertEquals(seqCnt, chunk.getSequenceCount());
View Full Code Here

Examples of org.graylog2.inputs.codecs.gelf.GELFMessage

58
59
60
61
62
63
64
65
66
67
68
69
70
71
    @Override
    public Result addChunk(ChannelBuffer buffer) {
        final byte[] readable = new byte[buffer.readableBytes()];
        buffer.toByteBuffer().get(readable, buffer.readerIndex(), buffer.readableBytes());

        final GELFMessage msg = new GELFMessage(readable);

        final ChannelBuffer aggregatedBuffer;
        switch (msg.getGELFType()) {
            case CHUNKED:
                try {
                    aggregatedBuffer = checkForCompletion(msg);
                    if (aggregatedBuffer == null) {
                        return VALID_EMPTY_RESULT;
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.