Jonas Bonér
dcd49bd052
Added configuration to define capacity to the remote client buffer messages on failure to send
2011-03-29 17:07:41 +02:00
Jonas Bonér
0412ae4151
Renamed config option for remote client retry message send.
2011-03-28 09:05:16 +02:00
Jonas Bonér
cf80e6a33d
1. Added config option to enable/disable the remote client transaction log for resending failed messages.
...
2. Swallows exceptions on appending to transaction log and do not complete the Future matching the message.
2011-03-27 22:58:50 +02:00
Viktor Klang
f853c05031
Potential fix for #723
2011-03-27 00:01:18 +01:00
Jonas Bonér
e6c658f58d
Changed UnknownRemoteException to CannotInstantiateRemoteExceptionDueToRemoteProtocolParsingErrorException - should be more clear now.
2011-03-25 16:25:36 +01:00
Jonas Bonér
5a9bfe9053
1. Fixed issues with remote message tx log.
...
2. Added trait for network failure testing that supports 'TCP RST', 'TCP DENY' and message throttling/delay.
3. Added test for the remote transaction log. Both for TCP RST and TCP DENY.
2011-03-25 16:06:55 +01:00
Jonas Bonér
331b5c7b74
Added accessor for pending messages
2011-03-25 08:36:43 +01:00
Jonas Bonér
f2ebd7a2f4
1. Added a 'pending-messages' tx log for all pending messages that are not yet delivered to the remote host, this tx log is retried upon successful remote client reconnect.
...
2. Fixed broken code in UnparsableException and renamed it to UnknownRemoteException.
2011-03-24 16:58:59 +01:00
Jonas Bonér
6449fa940f
refactored remote event handler and added deregistration of it on remote shutdown
2011-03-24 12:48:40 +01:00
Jonas Bonér
cb0f14a2c0
Added a remote event handler that pipes remote server and client events to the standard EventHandler system
2011-03-24 12:28:01 +01:00
Jonas Bonér
a8991ac538
Merge branch 'master' of github.com:jboner/akka
2011-03-23 15:12:32 +01:00
Jonas Bonér
6429086b51
Moved EventHandler to 'akka.event' plus added 'error' method without exception param
2011-03-23 15:12:09 +01:00
Viktor Klang
dfbc694059
Adding synchronous writes to NettyRemoteSupport
2011-03-23 15:00:29 +01:00
Viktor Klang
db1b50a6b6
Adding OrderedMemoryAwareThreadPoolExecutor with an ExecutionHandler to the NettyRemoteServer
2011-03-23 11:31:19 +01:00
Viktor Klang
e33eefa1d2
Rewriting getClassFor to do a fall-back approach, first test the specified classloader, then test the current threads context loader, then try the ReflectiveAccess` classloader and the Class.forName
2011-03-20 18:32:32 +01:00
Jonas Bonér
233044f077
Merge branch 'master' of github.com:jboner/akka
2011-03-19 12:22:17 +01:00
Jonas Bonér
299f865156
Fixed bug with restarting supervised supervisor that had done linking in constructor + Changed all calls to EventHandler to use direct 'error' and 'warning' methods for improved performance
2011-03-18 23:04:48 +01:00
Viktor Klang
d738674eeb
Switching to PoisonPill to shut down Per-Session actors, and restructuring some Future-code to avoid wasteful object creation
2011-03-18 18:03:10 +01:00
Viktor Klang
76f058edac
Fixing stall issue in remote pipeline
2011-03-18 10:41:49 +01:00
Viktor Klang
ac51509184
Removign leftover debug statement. My bad.
2011-03-14 17:04:21 +01:00
Viktor Klang
0899fa44ab
Merge with master
2011-03-14 16:29:22 +01:00
Viktor Klang
2a390d3fcb
All tests pass, might actually have solved the typed actor method resolution issue
2011-03-14 14:17:54 +01:00
Viktor Klang
cce0fa8b8f
Pulling out _resolveMethod_ from NettyRemoteSupport and moving it into ReflectiveAccess
2011-03-14 12:17:59 +01:00
Viktor Klang
b5b46aaff0
Potential fix for the remote dispatch of TypedActor methods when overloading is used.
2011-03-14 11:49:37 +01:00
Viktor Klang
49338dc9ed
Fixing ReadTimeoutException, and implement proper shutdown after timeout
2011-03-14 11:21:41 +01:00
Jonas Bonér
978ec62c1a
Merge branch 'master' of github.com:jboner/akka
2011-03-14 10:45:55 +01:00
Jonas Bonér
f8ce3d541e
Changed API for EventHandler and added support for log levels
2011-03-14 10:45:49 +01:00
Viktor Klang
9f4144c5f3
Changing order as to avoid DNS lookup in worst-case scenario
2011-03-09 16:45:04 +01:00
Viktor Klang
1301e301ef
Merge branch 'master' of github.com:jboner/akka
2011-03-09 13:32:11 +01:00
Viktor Klang
f8e9c61134
Removing legacy, non-functional, SSL support from akka-remote
2011-03-09 13:24:17 +01:00
Viktor Klang
7b2e2a66fc
Removing dead code
2011-03-08 12:03:32 +01:00
Viktor Klang
0375e7860b
Removed some superfluous code
2011-03-05 23:50:50 +01:00
Viktor Klang
28e2941449
Add Future GC comment
2011-03-05 23:50:36 +01:00
Viktor Klang
3bd83e5388
Adding support for clean exit of remote server
2011-03-05 23:42:39 +01:00
Viktor Klang
d8c556bb39
Merge remote branch 'origin/0deps' into 0deps
2011-03-02 18:48:43 +01:00
Viktor Klang
1e72fbfe8b
Potential fix for #672
2011-03-02 18:48:13 +01:00
Jonas Bonér
793ad9ac03
Renamed to EventHandler and added 'info, debug, warning and error'
2011-03-02 18:19:17 +01:00
Jonas Bonér
c4e2d73668
Added the ErrorHandler notifications to all try-catch blocks
2011-03-02 00:14:45 +01:00
Jonas Bonér
9354f0790c
Removed logging
2011-02-28 22:54:32 +01:00
Viktor Klang
d7ae45dd75
Potential fix for race-condition in RemoteClient
2011-02-11 20:13:42 +01:00
Viktor Klang
9f21b22dc3
Fixing ticket #652 - Reaping expired futures
2011-02-08 15:06:13 +01:00
Viktor Klang
810f6cfca9
Fixing #648 Adding support for configuring Netty backlog in akka config
2011-02-07 10:31:33 +01:00
Peter Vlugter
6a93610bda
Fix for local actor ref home address
...
- home address is set on deserialization
- flag for client-managed actor ref so that having
a home address doesn't imply client-managed
2011-02-04 15:16:46 +13:00
Viktor Klang
588b726bc4
Fixing a possible race-condition in netty
2011-01-31 12:41:39 +01:00
Viktor Klang
df2e5113d2
Making optimizeLocal public
2011-01-05 17:30:56 +01:00
Viktor Klang
71596343c6
Minor code cleanup and deprecations etc
2011-01-05 16:36:50 +01:00
Viktor Klang
f0e9732b7f
Fixing ticket #603
2011-01-05 11:43:49 +01:00
Viktor Klang
00840c8f5a
Adding support for non-delivery notifications on server-side as well + more code cleanup
2011-01-03 14:44:15 +01:00
Viktor Klang
7a0e8a82de
Major code clanup, switched from nested ifs to match statements etc
2011-01-03 13:49:39 +01:00
Viktor Klang
a61e591b2a
Putting the Netty-stuff in akka.remote.netty and disposing of RemoteClient and RemoteServer
2011-01-03 12:42:30 +01:00
