Skip to content

Commit 32f96df

Browse files
author
Sasha Ovsankin
committed
Issue 64 Incorporated second async patch from Matthijs
1 parent 68a55ac commit 32f96df

File tree

4 files changed

+7
-13
lines changed

4 files changed

+7
-13
lines changed

src/org/jabsorb/client/async/AsyncSessionUtil.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818
public class AsyncSessionUtil {
1919
private static final Logger log = LoggerFactory.getLogger(AsyncSessionUtil.class);
2020

21-
public static Session ToSyncSession(final AsyncSession asyncSession) {
21+
public static Session toSyncSession(final AsyncSession asyncSession) {
2222
// unwrap if possible
2323
if (asyncSession instanceof AsyncedSyncSession) {
2424
return ((AsyncedSyncSession)asyncSession).getSession();
@@ -27,7 +27,7 @@ public static Session ToSyncSession(final AsyncSession asyncSession) {
2727
return new SyncedAsyncSession(asyncSession);
2828
}
2929

30-
public static AsyncSession ToAsyncSession(final Session session) {
30+
public static AsyncSession toAsyncSession(final Session session) {
3131
// unwrap if possible
3232
if (session instanceof SyncedAsyncSession) {
3333
return ((SyncedAsyncSession)session).getAsyncSession();

test/src/org/jabsorb/client/async/AsyncSessionUtilTest.java

+5-6
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ public class AsyncSessionUtilTest extends TestCase {
2323
public void testToSyncSession() throws Exception {
2424
final AsyncSession asyncSession = new DummyAsyncSession(1000, "testToSyncSession");
2525

26-
final Session session = AsyncSessionUtil.ToSyncSession(asyncSession);
26+
final Session session = AsyncSessionUtil.toSyncSession(asyncSession);
2727

2828
long time = System.currentTimeMillis();
2929
final JSONObject response = session.sendAndReceive(null);
@@ -41,7 +41,7 @@ public void testToSyncSession() throws Exception {
4141
public void testToAsyncSession() throws Exception {
4242
final Session session = new DummySession(1000, "testToAsyncSession");
4343

44-
final AsyncSession asyncSession = AsyncSessionUtil.ToAsyncSession(session);
44+
final AsyncSession asyncSession = AsyncSessionUtil.toAsyncSession(session);
4545

4646
long time = System.currentTimeMillis();
4747
final Future<JSONObject> future = asyncSession.send(null);
@@ -61,14 +61,13 @@ public void testToAsyncSession() throws Exception {
6161
public void testToAsyncSessionCallback() throws Exception {
6262
final Session session = new DummySession(1000, "testToAsyncSessionCallback");
6363

64-
final AsyncSession asyncSession = AsyncSessionUtil.ToAsyncSession(session);
64+
final AsyncSession asyncSession = AsyncSessionUtil.toAsyncSession(session);
6565

6666
final long time = System.currentTimeMillis();
6767

6868
final boolean[] callbackCalled = new boolean[] { false };
6969

7070
final Future<JSONObject> future = asyncSession.send(null, new AsyncResultCallback<AsyncSession, JSONObject, JSONObject>() {
71-
@Override
7271
public void onAsyncResult(final AsyncSession source, final Future<JSONObject> result, final JSONObject context) {
7372
try {
7473
assertEquals("testToAsyncSessionCallback", result.get().get(JSONSerializer.RESULT_FIELD));
@@ -92,11 +91,11 @@ public void onAsyncResult(final AsyncSession source, final Future<JSONObject> re
9291

9392
public void testUnwrapSession() throws Exception {
9493
final Session session = new DummySession(1000, "testUnwrapSession");
95-
assertSame(session, AsyncSessionUtil.ToSyncSession(AsyncSessionUtil.ToAsyncSession(session)));
94+
assertSame(session, AsyncSessionUtil.toSyncSession(AsyncSessionUtil.toAsyncSession(session)));
9695
}
9796

9897
public void testUnwrapAsyncSession() throws Exception {
9998
final AsyncSession session = new DummyAsyncSession(1000, "testUnwrapSession");
100-
assertSame(session, AsyncSessionUtil.ToAsyncSession(AsyncSessionUtil.ToSyncSession(session)));
99+
assertSame(session, AsyncSessionUtil.toAsyncSession(AsyncSessionUtil.toSyncSession(session)));
101100
}
102101
}

test/src/org/jabsorb/client/async/DummyAsyncSession.java

-3
Original file line numberDiff line numberDiff line change
@@ -18,12 +18,10 @@ public DummyAsyncSession(final int duration, final String response) {
1818
this.response = response;
1919
}
2020

21-
@Override
2221
public void close() {
2322
// nothing
2423
}
2524

26-
@Override
2725
public Future<JSONObject> send(final JSONObject request, final AsyncResultCallback<AsyncSession, JSONObject, JSONObject> callback) {
2826
final SettableFuture<JSONObject> future = new SettableFuture<JSONObject>();
2927

@@ -52,7 +50,6 @@ public void run() {
5250
return future;
5351
}
5452

55-
@Override
5653
public Future<JSONObject> send(final JSONObject request) {
5754
return send(request, null);
5855
}

test/src/org/jabsorb/client/async/DummySession.java

-2
Original file line numberDiff line numberDiff line change
@@ -19,12 +19,10 @@ public DummySession(final int duration, final String response) {
1919
this.response = response;
2020
}
2121

22-
@Override
2322
public void close() {
2423
// nothing
2524
}
2625

27-
@Override
2826
public JSONObject sendAndReceive(final JSONObject message) {
2927
try {
3028
Thread.sleep(duration);

0 commit comments

Comments
 (0)