Skip to content
Browse files

Some test

  • Loading branch information...
1 parent 7056ba9 commit a1b368d00359e75024b39bce33630ca7cc461e1f @GLitchfield GLitchfield committed
View
7 ...ddf-datalink/src/main/java/com/barchart/feed/ddf/datalink/provider/ListenerClientDDF.java
@@ -70,12 +70,11 @@
boot.setPipelineFactory(pipelineFactory);
boot.setOption("broadcast", "false");
- boot.setOption("sendBufferSize", 1048576);
- boot.setOption("receiveBufferSize", 1048576);
+ // boot.setOption("receiveBufferSize", 2097152);
boot.setOption("receiveBufferSizePredictorFactory",
- new AdaptiveReceiveBufferSizePredictorFactory(1048576, 1048576,
- 2097152));
+ new AdaptiveReceiveBufferSizePredictorFactory(1048576, 2097152,
+ 4194304));
}
View
28 ...talink/src/test/java/com/barchart/feed/ddf/datalink/example/ExampleFeedStateListener.java
@@ -0,0 +1,28 @@
+/**
+ *
+ */
+package com.barchart.feed.ddf.datalink.example;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.barchart.feed.ddf.datalink.api.DDF_FeedStateListener;
+import com.barchart.feed.ddf.datalink.enums.DDF_FeedState;
+
+/**
+ * @author g-litchfield
+ *
+ */
+public class ExampleFeedStateListener implements DDF_FeedStateListener {
+
+ private static final Logger log = LoggerFactory
+ .getLogger(ExampleFeedStateListener.class);
+
+ @Override
+ public void stateUpdate(final DDF_FeedState state) {
+
+ log.debug("Feed state update: " + state.toString());
+
+ }
+
+}

0 comments on commit a1b368d

Please sign in to comment.
Something went wrong with that request. Please try again.