raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Docs - re-order Java snippet delimiters for Getting Started Guide Part 4 #23966

Browse source
This commit is contained in:
Mark James 2017-11-14 00:41:56 +01:00
parent 1cdd205c02
commit 711ac5730b
1 changed files with 13 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

18
akka-docs/src/test/java/jdocs/tutorial_4/DeviceGroup.java
View file

@ -18,6 +18,8 @@ import jdocs.tutorial_4.Device;
import jdocs.tutorial_4.DeviceManager;
//#device-group-full
//#device-group-remove
//#device-group-register
public class DeviceGroup extends AbstractActor {
private final LoggingAdapter log = Logging.getLogger(getContext().getSystem(), this);
@ -27,11 +29,11 @@ public class DeviceGroup extends AbstractActor {
this.groupId = groupId;
}
//#device-group-register
public static Props props(String groupId) {
return Props.create(DeviceGroup.class, groupId);
}
//#device-group-register
//#device-group-remove
public static final class RequestDeviceList {
final long requestId;
@ -50,10 +52,8 @@ public class DeviceGroup extends AbstractActor {
this.ids = ids;
}
}
//#device-group-remove
//#device-group-register
//#device-group-register
//#device-group-register
//#device-group-remove
final Map<String, ActorRef> deviceIdToActor = new HashMap<>();
//#device-group-register
@ -92,10 +92,13 @@ public class DeviceGroup extends AbstractActor {
);
}
}
//#device-group-register
//#device-group-remove
private void onDeviceList(RequestDeviceList r) {
getSender().tell(new ReplyDeviceList(r.requestId, deviceIdToActor.keySet()), getSelf());
}
//#device-group-remove
private void onTerminated(Terminated t) {
ActorRef deviceActor = t.getActor();
@ -104,16 +107,21 @@ public class DeviceGroup extends AbstractActor {
actorToDeviceId.remove(deviceActor);
deviceIdToActor.remove(deviceId);
}
//#device-group-register
@Override
public Receive createReceive() {
return receiveBuilder()
.match(DeviceManager.RequestTrackDevice.class, this::onTrackDevice)
//#device-group-register
//#device-group-remove
.match(RequestDeviceList.class, this::onDeviceList)
//#device-group-remove
.match(Terminated.class, this::onTerminated)
//#device-group-register
.build();
}
}
//#device-group-remove
//#device-group-register
//#device-group-remove
//#device-group-full