andsel
9b75a6a0a9
Fixed failing test
2016-03-06 20:02:10 +01:00
andsel
4e8f72a34b
Moved test to use a test client callback that queue up all received messages
2016-03-06 19:50:47 +01:00
andsel
6cadaebb0c
Minor, rewritten test to user Paho instead of fusesource mqtt client
2016-03-06 19:50:47 +01:00
andsel
efbfab7914
Minor, moved tests from ServerIntegrationFuseTest to ServerIntegrationPahoTest to limit the usage of fusesource mqtt client
2016-03-06 19:50:47 +01:00
Michael Konrad
f5a3d57afd
Enables client authentification for SSL
...
Client authentification can be set as with the SSL Properties to
require the client certificate to be signed by the server.
Added jUnit test and test certificates
2016-02-17 12:02:52 +01:00
andsel
5487303095
Merged parser_commons into netty_parser
2016-02-03 23:20:15 +01:00
andsel
5c7e2b357f
Fixed missed clean session for ClientSession, issue #145
2016-02-02 22:39:11 +01:00
andsel
d36de24349
Minor, modified access to fields of SubscribeMessage.Couple
2016-01-30 17:35:28 +01:00
andsel
a19af18a61
Moved read authorization check from publish phase to subscribe
2016-01-30 17:22:17 +01:00
andsel
8c14efb7d8
Added integration test to check issue #142
2016-01-30 11:46:06 +01:00
andsel
dfa75e145f
Fixed bug #143 avoid publication try to disconnected clients
2016-01-25 22:21:38 +01:00
andsel
43f7223a15
Minor refactory, renamed var names from session to channel
2016-01-24 19:21:24 +01:00
andsel
3be2667844
Minor refact, moved Channel's attributesKey accessible by utils methods
2016-01-24 19:21:24 +01:00
andsel
43371d3068
Minor refact, moved commons Channel attributes constants from NettyChannel to NettyUtils
2016-01-24 19:21:24 +01:00
andsel
7b1db3e1db
Refactoring, dropped unuseful ServerChannel abstraction in favor on Netty's Channel
2016-01-24 19:21:24 +01:00
andsel
beb556c73c
First clean of Moquette's channel abstraction to user Netty's one
2016-01-24 19:21:24 +01:00
andsel
4c1f36cf67
MOved the method nextClientID from IMessagesStore to the ISessionsStore because it's session related
2016-01-17 13:00:36 +01:00
andsel
163858e47b
Fixed bug in deletion of valid conn descriptor once different clients with same ID connects (issues #116 and #124 )
2015-12-27 13:19:16 +01:00
andsel
8e891da49f
Removed client active/not active state from persistence (issue #118 )
2015-12-19 18:01:54 +01:00
andsel
f44518ff27
Moved security SPI related interfaces into dedicated package
2015-12-13 16:42:04 +01:00
andsel
db66f19109
Added sleep in integration tests to let MQTT clients finish it's job when we need a serial behaviour
2015-12-08 19:46:43 +01:00
andsel
6cb67eb6c8
Fixed integration tests for internal publish
2015-12-08 19:27:47 +01:00
andsel
16a5556fa3
Added internal publish once the broker is embedded in hosting applications
2015-12-08 18:12:00 +01:00
andsel
6805cf89ee
Minor change, just renames
2015-12-08 15:15:51 +01:00
andsel
8c88567c78
Minor change, moved const definition from Constants inside parser-commons to BrokerConstants inside broker project
2015-12-08 14:04:35 +01:00
andsel
5a1cd97b71
Removed clean session flag from subscription and moved in the correct place (ClientSession)
2015-12-06 19:55:04 +01:00
andsel
80569d5dfe
Minor change, added a factory method for ClientTopicCouple built from Subscription
2015-12-06 19:31:36 +01:00
andsel
9ce9a6597f
Architechtural refactory, moved subscription out of tree and into db store
2015-12-06 11:43:29 +01:00
andsel
7325c8e7bc
Minor, cleaned imports
2015-12-01 23:00:42 +01:00
andsel
810d8a1af8
Removed TreeNode's parent reference to avoid maintaning a reference that could keep live big trees (solves #119 and #126 )
2015-12-01 22:59:38 +01:00
andsel
e3b6391653
Added 'autosave_interval' fix issue #97
2015-11-22 16:56:40 +01:00
andsel
371c740321
Moved project package from org.eclipse.moquette to io.moquette
2015-11-20 21:30:59 +01:00
andsel
f438ef7f49
Separated ISessionsStore and IMessagesStore Memory implementations
2015-11-19 00:16:18 +01:00
andsel
892eecfa2b
Separated ISessionsStore and IMessagesStore MapDB implementations
2015-11-19 00:15:43 +01:00
andsel
9f9d01ec58
Changed retained persistence to use the global message store and guids, instead of duplicate msg contents
2015-11-18 22:25:14 +01:00
andsel
fdf5b03983
Removed no more used methods
2015-11-16 23:53:10 +01:00
andsel
9236def453
Used the message store for QoS2 messages
2015-11-16 23:45:47 +01:00
andsel
7fb9198373
Fixed missed store/load of guid for StoredPublishEvent
2015-11-15 13:21:28 +01:00
andsel
02b23ef926
Fixed bad client session load on republish
2015-11-15 12:55:30 +01:00
andsel
2cd6077287
Fixed packetId missed cleanup
2015-11-15 12:54:30 +01:00
andsel
191a94e19d
First refactoring using the concept of ClientSession also for publish
2015-11-15 11:16:18 +01:00
andsel
ce1618cb52
Minor changes, refactored ConnectionDescriptor to be an immutable object
2015-11-10 22:24:35 +01:00
andsel
19dac6e32b
Refactored the disconenct and clean of session to use new ClientSession
2015-11-08 18:42:03 +01:00
andsel
9a18739a7f
Refactored ProtocolProcessor.processSubscribe to use the ClientSession concept instead of directe access to map storage concepts
2015-11-08 18:42:03 +01:00
andsel
c793ded63e
Introduced 'fat' ClientSession class responsible to model the concept of an MQTT client session
2015-11-08 18:42:03 +01:00
Sai Boorlagadda
874141e13b
deleted the file in teardown
2015-10-26 23:28:41 -07:00
andsel
165a0aebd5
Removed unusefull SubscriptionsStore.clearAllSubscriptions used only in tests
2015-10-17 21:08:06 +02:00
andsel
1d25839f53
Refactory, moved SubscriptionStore related method directly in the subscriptioStore from ProtocolProcessro
2015-10-17 20:43:53 +02:00
andsel
54c68a61c0
Added timeout check during shutdown of MapDB storage
2015-09-30 22:12:36 +02:00
andsel
f45c0a76e1
Changed the subscription tree to work as persistent tree
2015-09-29 22:29:25 +02:00
andsel