Package com.splunk

Examples of com.splunk.Receiver

37
38
39
40
41
42
43
44
45
    protected void doWrite(SplunkEvent event) throws IOException {
        Index index = getIndex();
        if (index != null) {
            index.submit(args, event.toString());
        } else {
            Receiver receiver = endpoint.getService().getReceiver();
            receiver.submit(args, event.toString());
        }
    }
View Full Code Here
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
    }

    @Override
    protected Socket createSocket(Service service) throws IOException {
        Index indexObject = null;
        Receiver receiver = null;
        Socket socket = null;

        if (index != null) {
            indexObject = service.getIndexes().get(index);
            if (indexObject == null) {
                throw new RuntimeCamelException(String.format("cannot find index [%s]", index));
            }
            socket = indexObject.attach(args);
        } else {
            receiver = service.getReceiver();
            socket = receiver.attach(args);
        }
        socket.setTcpNoDelay(true);
        LOG.trace(String.format("created a socket on %s", socket.getRemoteSocketAddress()));
        return socket;
    }
View Full Code Here
TOP

Related Classes of com.splunk.Receiver

  • org.apache.camel.component.splunk.support.StreamDataWriter
  • org.apache.camel.component.splunk.support.SubmitDataWriter
  • java.io.OutputStreamWriter
  • java.io.Writer
  • java.net.Socket
  • java.io.OutputStream
    • 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.