Skip to content

Commit

Permalink
[Java] Correct typo and use CommonContext.SPY_PREFIX.
Browse files Browse the repository at this point in the history
  • Loading branch information
mjpt777 committed Jul 4, 2016
1 parent fae5d09 commit 948d8b2
Showing 1 changed file with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,7 @@
*/
package io.aeron.driver;

import io.aeron.CommonContext;
import io.aeron.DriverProxy;
import io.aeron.driver.buffer.RawLogFactory;
import io.aeron.driver.media.ReceiveChannelEndpoint;
Expand Down Expand Up @@ -909,7 +910,7 @@ public void shouldBeAbleToAddNetworkPublicationThenSingleSpyThenRemoveSpy() thro
}

@Test
public void shouldTimeouSpy() throws Exception
public void shouldTimeoutSpy() throws Exception
{
driverProxy.addPublication(CHANNEL_4000, STREAM_ID_1);
final long idSpy = driverProxy.addSubscription(spyForChannel(CHANNEL_4000), STREAM_ID_1);
Expand Down Expand Up @@ -994,7 +995,7 @@ private long doWorkUntil(final BooleanSupplier condition) throws Exception

private static String spyForChannel(final String channel)
{
return "aeron-spy:" + channel;
return CommonContext.SPY_PREFIX + channel;
}

private static long networkPublicationCorrelationId(final NetworkPublication publication)
Expand Down

0 comments on commit 948d8b2

Please sign in to comment.