Skip to content
This repository has been archived by the owner on Nov 28, 2023. It is now read-only.

Commit

Permalink
clean up to meet style guide
Browse files Browse the repository at this point in the history
  • Loading branch information
zcourts committed Feb 20, 2014
1 parent fcc013f commit 3c5d1a2
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 6 deletions.
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
package com.datasift.client.exceptions;

import com.datasift.client.exceptions.DataSiftException;
import io.higgs.http.client.Response;

public class JsonParsingException extends DataSiftException {
Expand Down
4 changes: 2 additions & 2 deletions src/main/java/com/datasift/client/stream/StreamingData.java
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,8 @@ public void run() {
long now = DateTime.now().getMillis();
for (StreamingData data : streams) {
if (data.lastSeen != null) {
if (now - data.lastSeen.getMillis() >= TimeUnit.SECONDS.toMillis(CONNECTION_TIMEOUT_LIMIT)) {
if (now - data.lastSeen.getMillis() >=
TimeUnit.SECONDS.toMillis(CONNECTION_TIMEOUT_LIMIT)) {
data.closeAndReconnect();
}
}
Expand Down Expand Up @@ -84,7 +85,6 @@ public StreamingData(DataSiftConfig config) {
streams.add(this);
}


@Override
public synchronized void onConnect(ChannelHandlerContext ctx) {
streamEventListener.streamOpened();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -171,10 +171,8 @@ public void testIfUsageParamIsSentForCurrent() {
}

@Test
public void testIfWeCanGetStreamUsage(){

public void testIfWeCanGetStreamUsage() {
//m.setExpectedStreamData();

}

@Test
Expand Down

0 comments on commit 3c5d1a2

Please sign in to comment.