 andrea
|
6fb4682d8b
|
Added encode/decode for PubRel message
|
2013-09-12 17:14:21 +02:00 |
|
|
andrea
|
47bdb27261
|
Added encode/decode for PubRec message
|
2013-09-12 17:12:02 +02:00 |
|
|
andrea
|
dcffda5c4f
|
Added encode/decode for PubComp message
|
2013-09-12 17:08:20 +02:00 |
|
|
andrea
|
fa8a12a6f2
|
Added encode/decode for UnsubAck message
|
2013-09-12 17:00:21 +02:00 |
|
|
andrea
|
3066cfdd04
|
Added encode/decode for PingResp message
|
2013-09-12 16:53:33 +02:00 |
|
|
andrea
|
3fa3705d55
|
Added encode/decode for PingReq message
|
2013-09-12 16:50:36 +02:00 |
|
|
andrea
|
ef8f794b93
|
Added encode/decode for Disconnect message
|
2013-09-12 16:44:06 +02:00 |
|
|
andrea
|
52402536d9
|
Added encode/decode for Unsubscribe message
|
2013-09-12 16:28:51 +02:00 |
|
|
andrea
|
daa637c557
|
Minor cleaned imports
|
2013-09-12 16:14:51 +02:00 |
|
|
andrea
|
58017f45a1
|
Minor cleaned imports
|
2013-09-12 16:01:40 +02:00 |
|
|
andrea
|
2c9858c261
|
Added encode/decode for SubAck message
|
2013-09-12 15:58:53 +02:00 |
|
|
andrea
|
9f2497e0f9
|
Minor cleaned imports
|
2013-09-12 15:17:42 +02:00 |
|
|
andrea
|
c3f5a69d68
|
Added encode/decode for Subscribe message
|
2013-09-12 15:16:55 +02:00 |
|
|
andrea
|
1b1cc715be
|
Added encode/decode for PubAck message
|
2013-09-12 14:45:04 +02:00 |
|
|
andrea
|
facec04ac2
|
Minor cleaned imports
|
2013-09-12 14:30:25 +02:00 |
|
|
andrea
|
28b37f68ea
|
Added encode/decode for Publish message
|
2013-09-12 12:38:31 +02:00 |
|
|
andrea
|
4dd633cef8
|
Minor cleaned imports
|
2013-09-12 12:11:10 +02:00 |
|
|
andrea
|
4335a566f1
|
Minor cleaned imports
|
2013-09-12 09:19:31 +02:00 |
|
|
andrea
|
ecfc5e645a
|
Minor cleaned imports
|
2013-09-11 17:54:47 +02:00 |
|
|
andrea
|
1baa16b8e3
|
Extracted a TestUtils method mockChannelHandler
|
2013-09-11 17:51:59 +02:00 |
|
|
andrea
|
93859d1a63
|
Added encode/decode for ConnAck message
|
2013-09-11 17:48:07 +02:00 |
|
|
andrea
|
22fe25da32
|
Introduced hierarchy for message encoders
|
2013-09-11 16:47:41 +02:00 |
|
|
andrea
|
6afaa46cf4
|
Moved PubCompMessage to protocol commons module
|
2013-09-11 16:33:16 +02:00 |
|
|
andrea
|
24e34278aa
|
Introduced DemuxDecoder to root the hierarchy of all message decoders
|
2013-09-11 16:19:31 +02:00 |
|
|
andrea
|
103d772533
|
Minor changes
|
2013-09-11 15:44:15 +02:00 |
|
|
andrea
|
3f44eaee39
|
Added Connect encoder part
|
2013-09-11 15:42:00 +02:00 |
|
|
andrea
|
557c682a5e
|
Ported all existing test for MINA ConnectDecoder to Netty's
|
2013-09-11 11:25:34 +02:00 |
|
|
andrea
|
2ee84797ba
|
Introduced raw decoder for CONNECT messages
|
2013-09-11 11:06:53 +02:00 |
|
|
andrea
|
2886aa0bab
|
Extracted common pojo messages definitions
|
2013-09-10 15:00:18 +02:00 |
|
|
andrea
|
d9131b4b07
|
Added skeleton for Netty parser
|
2013-09-09 11:59:59 +02:00 |
|
|
andrea
|
23b4958592
|
Renamed parser to mina-parser
|
2013-09-09 11:04:43 +02:00 |
|
|
andrea
|
779a0a9d26
|
Minor fix, cleaned imports
|
2013-09-01 12:52:50 +02:00 |
|
|
selva.andre
|
13b211e813
|
Merge branch 'protocol_processor_extraction'
Splitted lmax messsaging part from protocol processing part
|
2013-08-30 19:23:08 +02:00 |
|
|
andrea
|
78daf36418
|
Minor fix, cleaned imports
|
2013-08-30 19:21:55 +02:00 |
|
|
andrea
|
0694f28f32
|
Simplified APIs
|
2013-08-30 19:21:11 +02:00 |
|
|
andrea
|
2c11cade06
|
Removed a ping pong beteen the ProtocolProcessor and SimpleMessaging, avoid call method, send Event, receive Event e callback a method into ProcotolProcessor
|
2013-08-30 19:05:09 +02:00 |
|
|
andrea
|
ff0139d809
|
Changed some methods visibility
|
2013-08-30 18:55:11 +02:00 |
|
|
andrea
|
2b7858de7c
|
Minor change, cleaned imports
|
2013-08-30 18:10:41 +02:00 |
|
|
andrea
|
e579180abf
|
Moved MemoryStorageService from test to src
|
2013-08-30 18:10:12 +02:00 |
|
|
andrea
|
635d37112e
|
Renamed DummyStorageService to MemoryStorageService
|
2013-08-30 18:09:24 +02:00 |
|
|
andrea
|
63333b11ad
|
Completed the memory implementation of DummyStorageService
|
2013-08-30 18:08:06 +02:00 |
|
|
andrea
|
d2554788ea
|
Added memory implementation of DummyStorageService for the subscriptions part
|
2013-08-30 17:40:56 +02:00 |
|
|
andrea
|
22269ccfb1
|
Removed empty test case
|
2013-08-30 17:06:48 +02:00 |
|
|
andrea
|
fb7c137a11
|
Moved processSubscribe into ProtocolProcessor
|
2013-08-30 17:06:15 +02:00 |
|
|
andrea
|
dd4ca33ed0
|
Moved processPublish from SimpleMessaging
|
2013-08-30 16:14:50 +02:00 |
|
|
andrea
|
90e2277490
|
Moved processUnsubscribe into ProtocolProcessor
|
2013-08-30 15:00:51 +02:00 |
|
|
andrea
|
b3293a031f
|
Moved processDisconnect into ProtocolProcessor
|
2013-08-30 14:53:57 +02:00 |
|
|
andrea
|
353b70d6c7
|
Moved processPubComp into ProtocolProcessor
|
2013-08-30 13:28:55 +02:00 |
|
|
andrea
|
e74f6d5655
|
Moved processPubRec into ProtocolProcessor
|
2013-08-30 13:24:53 +02:00 |
|
|
andrea
|
7d0cb70584
|
Moved processPubRel and processPubComp into ProtocolProcessor
|
2013-08-30 13:23:06 +02:00 |
|