Skip to content

Commit 935aeca

Browse files
author
Damien Dallimore
committed
new release
1 parent 1d247c7 commit 935aeca

File tree

6 files changed

+8
-7
lines changed

6 files changed

+8
-7
lines changed

TODO

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1,2 @@
1-
Build in final release Splunk Java SDK
1+
maven/gradle (jar dependencys)
2+
version tagging

build/build.properties

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
version=0.3.0
1+
version=1.0
22

33
src=src
44
classes=classes

lib/splunk-sdk.jar

-3.5 KB
Binary file not shown.

lib/splunk.jar

100755100644
271 KB
Binary file not shown.

releases/splunklogging-1.0.tar.gz

1.59 MB
Binary file not shown.

src/com/dtdsoftware/splunk/logging/SplunkRestInput.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
import java.net.Socket;
88

99
import com.splunk.Args;
10-
import com.splunk.Receivers;
10+
import com.splunk.Receiver;
1111
import com.splunk.Service;
1212

1313
/**
@@ -21,7 +21,7 @@ public class SplunkRestInput extends SplunkInput {
2121

2222
// Java SDK objects
2323
private Service service;
24-
private Receivers receivers;
24+
private Receiver receivers;
2525
private Args args;
2626

2727
// connection props
@@ -74,7 +74,7 @@ private void initService() {
7474

7575
this.service = new Service(host, port);
7676
this.service.login(user, pass);
77-
this.receivers = new Receivers(this.service);
77+
this.receivers = service.getReceiver();
7878

7979
}
8080

@@ -152,13 +152,13 @@ public void sendEvent(String message) {
152152

153153
try {
154154
if (streamSocket == null) {
155-
this.receivers.submit(currentMessage, args);
155+
this.receivers.log(args,currentMessage);
156156

157157
// flush the queue
158158
while (queueContainsEvents()) {
159159
String messageOffQueue = dequeue();
160160
currentMessage = messageOffQueue;
161-
this.receivers.submit(currentMessage, args);
161+
this.receivers.log(args,currentMessage);
162162
}
163163
}
164164
} catch (Exception e) {

0 commit comments

Comments
 (0)