f194f92418
Shutdown the connection if no more data received
2017-03-23 16:30:23 +08:00
3c8de09ba3
Rename the env 'queue' to 'mqueue'
2017-03-23 15:20:32 +08:00
06100ae6d5
Define 'MQueue' macro
2017-03-23 15:15:45 +08:00
690f27a8b4
Support 'mount point'
2017-03-23 15:10:24 +08:00
496d046d52
Improve the mqueue design
2017-03-23 15:07:06 +08:00
0d617c17e0
Use the emqttd_protocol:init/4 API
2017-03-23 15:06:14 +08:00
0b13cd78e6
Version 2.2
2017-03-22 10:48:24 +08:00
2e6e97b006
Fix the syntax error
2017-03-13 16:30:41 +08:00
82bb7766ac
Add env, maintainers, licenses properties
2017-03-13 15:55:00 +08:00
d099d0b53c
Add emqttd_gc:maybe_force_gc/3 API and tune the min hibernate interval
2017-03-13 15:36:58 +08:00
05396f0ade
Add pbkdf2 dependencies and fix the building errors
2017-03-13 13:30:49 +08:00
90e46325df
Fix the crash caused by keepalive:start/3
2017-03-13 12:42:02 +08:00
bb91bc04c6
Merge pull request #941 from callbay/issue#935
...
Fix Issue#935
2017-03-13 11:41:22 +08:00
6472457342
Match {error,einval}
2017-03-12 23:06:57 +08:00
61a71e7559
update emqttd_auth_mod.erl code format
2017-03-12 11:49:26 +08:00
bd8b446a54
Merge pull request #938 from emqtt/pbkdf2
...
Support pbkdf2 hash
2017-03-10 08:21:14 +08:00
b5ff80499a
Update emqttd_auth_mod.erl
2017-03-09 09:29:31 +08:00
fba79b3e25
support pbkdf2
2017-03-08 18:01:59 +08:00
e008d149d3
Update comments and misc fix
2017-03-06 18:57:29 +08:00
7c90e08f57
Fix the subscrptions print
2017-03-06 18:48:29 +08:00
14d28d59bd
Rename the 'Timestamp' variable to 'TS'
2017-03-06 18:47:50 +08:00
f2a818a4a4
Rename the PUBSUB macro to PS
2017-03-06 18:46:09 +08:00
dae3d22bef
Remove the io:format line
2017-03-06 18:43:44 +08:00
93719a13f3
Edit the note of tick timer
2017-03-03 22:05:26 +08:00
a71a061305
add app.src,rebar.lock, ignores for rebar3
...
Having src/emqttd.app.src allows rebar family of build tools
(rebar2, and rebar3) to be used to compile emqttd. This is important
to allow plugins to be written using rebar3, to lock dependencies.
rebar.lock contains references to commits or hashes of dependencies
and is used by rebar3 to allow repeatable builds.
This is important since without it, updates to dependencies are
silently pulled and it is impractical to replicate a build properly.
However, this adds an additional maintenance effort. Periodically,
the lock file must be updated using rebar3 upgrade, and app.src
must be updated when adding new dependencies.
Note that erlang.mk does not respect dependency locking currently,
and does not benefit from rebar.lock.
_build is used by rebar3 and mix for storing built artifacts.
2017-02-27 14:19:04 +05:30
1e91c0e220
Format code
2017-02-23 23:01:20 +08:00
440011da9a
Rename 'Pkt' to 'PktCnt', 'Msg' to 'MsgCnt'
2017-02-23 23:00:55 +08:00
edd99dc5ed
Disable the force GC if conn_force_gc_count = 0
2017-02-23 18:53:16 +08:00
1e36750288
Use emqttd_gc:reset_conn_gc_count/2 API
2017-02-23 17:40:50 +08:00
5ef4fce141
Handle the {ok, I} return
2017-02-23 17:26:29 +08:00
e972103f74
Fix the 'spawn_opt' options
2017-02-23 17:25:44 +08:00
73847b96fc
Add 'FULLSWEEP_OPTS' macro
2017-02-23 17:16:55 +08:00
7d65ad42ad
Add '[{fullsweep_after, 10}]' opts and 'force_gc_count' to tune the memory usage
2017-02-23 16:56:16 +08:00
ab76e7978b
Add emqttd_gc module
2017-02-23 16:53:09 +08:00
2d9dbe4729
Support to hook 'tag' function
2017-02-23 11:55:52 +08:00
365bfb9e80
Replace emqttd_misc:inc_stats/1 with inc_stats/1
2017-02-22 23:08:22 +08:00
239cf1b5fc
Add '{backoff, 1000, 1000, 10000}' to return of init/1
2017-02-22 23:07:27 +08:00
b8084f2989
Remove inc_stats/1 function
2017-02-22 22:24:23 +08:00
5d5de51f89
Change the gen_server:start_link to gen_server2
2017-02-22 18:47:14 +08:00
5543b72243
Force to GC the Websocket Process
2017-02-22 18:41:02 +08:00
f955614f9d
Remove the io:format line
2017-02-22 18:40:17 +08:00
39abdb8b41
Remove 'enable_stats' from 'INFO_KEYS', and remove io:format line
2017-02-22 17:52:55 +08:00
88c2b4eaa3
Use the new emqttd_parser API to parse Websocket frame
2017-02-22 15:43:24 +08:00
b4936726fd
Remove the random:seed/1 to fix the build warnings
2017-02-22 15:36:06 +08:00
f4c4e5635c
Improve the 'enable_stats' design of client, session
2017-02-22 12:10:52 +08:00
700ec7aaef
Add 'proto_stats' record
2017-02-22 10:01:39 +08:00
6c50a59cad
Rename macro 'MAX_PACKET_LEN' to 'MAX_PACKET_SIZE'
2017-02-22 00:32:22 +08:00
418fb37ca0
Add max_packet_size() type
2017-02-22 00:31:47 +08:00
d33a41b28b
Remove unused fields: connname, peerhost, peerport
2017-02-22 00:31:09 +08:00
17953a4716
Rename 'MAX_LEN' to 'MAX_PACKET_LEN'
2017-02-21 20:11:09 +08:00
4d2d6fa0d6
Change the default max_len to infinity
2017-02-21 20:10:38 +08:00
7e98650233
Improve the emqttd_parser design
2017-02-21 20:10:17 +08:00
498915e5b3
Hibernate after a packet sent
2017-02-21 19:26:50 +08:00
3cdf2377c8
Use gen_server2 to reduce the CPU/memory usage
2017-02-21 18:45:40 +08:00
cabd1af23a
Hiberate after subscribe, unsubscribe and resume
2017-02-20 16:45:53 +08:00
a7ed2c402b
fix #885
2017-02-18 15:03:41 +08:00
79217fdade
Remove the 'infinity' timeout
2017-02-18 14:14:24 +08:00
726f829df5
Fix the error caused by emqttd:env/1
2017-02-16 18:59:53 +08:00
5419266724
emqttd_hook -> emqttd_hooks, syslog
2017-02-16 18:33:57 +08:00
a5ba86fd1a
Update rebar.config
2017-02-16 11:46:21 +08:00
bad855bdd9
Improve the session design, support tune_qos, enable_stats
2017-02-16 11:46:06 +08:00
a345b3682b
Rename emqttd_hook to emqttd_hooks
2017-02-16 11:39:48 +08:00
45a379f112
Replace 'size/1' with 'byte_size/1', serialize to output iolist
2017-02-16 11:38:40 +08:00
d69d769797
Upgrade copyright info
2017-02-16 11:36:57 +08:00
78c8856eda
Update copyright info
2017-02-16 11:36:24 +08:00
fa8882b499
Support client, session stats
2017-02-16 11:36:08 +08:00
d91e49a5a5
Change the restart strategy of the top supervisor
2017-02-16 11:35:33 +08:00
d5ac9f0dcb
Update protocol_name/1, type_name/1 functions for MQTT 5
2017-02-16 11:33:50 +08:00
bbbfafb759
Update protocol_name/1, type_name/1 functions for MQTT 5
2017-02-16 11:33:27 +08:00
67566ca372
Add dropped/1 function
2017-02-16 11:32:24 +08:00
a5ac32b49b
add 'packets/puback/missed', 'packets/pubrec/missed', 'packets/pubrel/missed', 'packets/pubcomp/missed' metrics
2017-02-16 11:31:46 +08:00
6b22fb0a0c
Remove the 'DOWN' client from emqttd_stats
2017-02-16 11:30:43 +08:00
2021667021
Add 'local_session/0 function, change reg_session/3 unreg_session/1 functions
2017-02-16 11:29:55 +08:00
5a49196a07
Update copyright info and format code
2017-02-16 11:28:35 +08:00
a54076cf0a
Change the 'Env'
2017-02-16 11:25:44 +08:00
90ff296ebe
Improve the module and support statistics
2017-02-16 11:25:10 +08:00
23e49c317d
Improve the module and support statistics
2017-02-16 11:24:46 +08:00
dbcd79fb74
Move the 'MQTT_SOCKOPTS' macro to include/emqttd_protocol.hrl
2017-02-16 11:22:48 +08:00
1222746b79
Update copyright and format code
2017-02-16 11:21:31 +08:00
d93caa7c9e
Update copyright and format code
2017-02-16 11:19:02 +08:00
640c9287c2
Rename now_to_secs, now_to_ms functions
2017-02-16 11:18:37 +08:00
796d5df1c0
Upgrade parse/2 function
2017-02-16 11:17:57 +08:00
0019fb2b49
Change the message timestamp to 'os:timestamp()'
2017-02-16 11:10:47 +08:00
9e0b2ed57b
Update copyright and change the format of -type, -callback
2017-02-16 11:07:47 +08:00
cae247be97
Rename 'emqttd_hook' module to 'emqttd_hooks'
2017-02-16 10:56:53 +08:00
0bc071d792
Add emqttd_misc module
2017-02-16 10:48:31 +08:00
08100525a5
Add inflight module and test suite
2017-02-16 10:44:00 +08:00
a59d5bb459
Rename the emqttd_time APIs
2017-02-15 22:05:28 +08:00
aefe0ab4ac
Add ClientId parameter into the auth on HTTP Publish
2017-02-07 18:24:37 +08:00
8e60b8f00a
Remove gen_logger references
2017-01-23 20:02:02 -05:00
4606eaeb58
delete a comma.
2017-01-16 16:27:10 +08:00
ff6acbf293
Client unsubscribe hook does not handle 'stop' value.
...
Insert a statement to prevent calling emqttd_session:unsubscribe() if hook returns stop.
2017-01-16 16:24:19 +08:00
0cd4afaa8e
Merge pull request #855 from emqtt/emq20
...
Copyright (c) 2016-2017
2017-01-12 10:49:06 +08:00
101532980b
Update emqttd_pmon.erl
...
Copyright (c) 2016-2017
2017-01-11 21:38:34 +08:00
6af4badc0a
Merge pull request #854 from emqtt/emq20
...
Copyright (c) 2012-2017
2017-01-11 21:12:52 +08:00
8092543efb
Copyright (c) 2012-2017
2017-01-11 19:34:48 +08:00
06ca13531e
Change "ok" message to uppercase
2016-12-27 17:21:27 +08:00
737a89d5e8
rm net_adm:ping
2016-12-14 18:09:41 +08:00
15a2b265be
fixed cluster fail
2016-12-13 16:57:18 +08:00
696647f2cf
fixed #413
2016-12-13 15:57:22 +08:00
8c1f5d7ec1
Unauthorized
2016-12-13 10:27:05 +08:00
ed730f6827
Fix issue#814 - Cannot remove a 'DOWN' node from the cluster
2016-12-12 19:25:49 +08:00
fa99cdcaa5
Local Subscription Routes show
2016-12-08 19:34:38 +08:00
470a933938
Shared Subscription CLI
2016-12-08 18:06:48 +08:00
7abc667f7d
iolist_size/1
2016-12-07 19:15:44 +08:00
49ebed5b0b
iolist_size
2016-12-07 18:37:47 +08:00
c59f43cdd2
Merge branch 'emq20' of https://github.com/emqtt/emqttd into emq20
2016-12-05 15:00:22 +08:00
0206785577
fix ws metrics
2016-12-05 15:00:09 +08:00
d62593a9c6
kickout
2016-12-02 09:17:06 +08:00
2181bd7850
unload
2016-12-01 19:12:45 +08:00
281ab7b929
fixed stop appliaction error log
2016-12-01 17:05:08 +08:00
8116357d07
Merge branch 'emq20' of https://github.com/emqtt/emqttd into emq20
2016-12-01 15:18:29 +08:00
fc14f4a3b6
rename route table
2016-12-01 15:18:05 +08:00
0b93391050
fix issue#151
2016-12-01 10:39:14 +08:00
3db876781b
handshake_timeout change
2016-11-03 11:04:57 +08:00
eb9c11f321
remove modules
2016-10-31 20:26:56 +08:00
031a288b50
Update emqttd_pubsub.erl
...
modify table name
2016-10-31 20:22:09 +08:00
b82e67b081
fixed emqtt/emqttd#739
2016-10-31 14:42:22 +08:00
611ca0dca4
move modules to plugins
2016-10-31 10:46:22 +08:00
a87f4917ae
subscriptions cmd
2016-10-18 18:06:35 +08:00
d2d425dc7e
sessions cmd
2016-10-18 17:14:36 +08:00
c41f2c97f3
fix print subscription
2016-10-18 11:02:30 +08:00
5461cc357a
dump subscriptions
2016-10-18 10:56:41 +08:00
ce02ec7816
emq_auth_username
2016-10-18 10:45:36 +08:00
507bca6f52
fix stop_listener/1
2016-10-17 12:41:14 +08:00
e85ad35d35
move to emqtt/emq_auth_clientid plugin
2016-10-15 17:36:40 +08:00
bf075a125b
move to emqtt/emq_auth_username plugin
2016-10-15 17:36:19 +08:00
b0917e665c
etc/acl.conf
2016-10-15 13:49:51 +08:00
12d362a674
support .config suffix
2016-10-14 17:40:20 +08:00
f977f9a908
start https listener
2016-10-14 16:21:50 +08:00
7ac3416d51
modules
2016-10-14 14:25:21 +08:00
1a8136d551
move to emqtt/emq_mod_rewrite
2016-10-14 13:00:59 +08:00
73659208a1
allow_anonymous
2016-10-13 19:09:49 +08:00
a01f642606
mqtt listeners
2016-10-13 17:37:32 +08:00
1f50175c6f
rm emqttd_plugins:init/0
2016-10-12 19:42:10 +08:00
0e4b7cf768
rm src/emqttd.app.src
2016-10-11 14:46:35 +08:00
14ba1e1c89
emqttd:env
2016-10-11 10:09:29 +08:00
113bfc73a8
env
2016-10-11 10:01:39 +08:00
d88a4093a5
emqttd:env
2016-10-11 09:49:24 +08:00
2bcffab28a
replace 'emqttd:conf' with 'emqttd:env'
2016-10-11 09:46:28 +08:00
c0c79e8171
rm gen_conf and emqttd_conf
2016-10-11 09:09:29 +08:00
99632bfbb6
rm gen_conf
2016-10-09 09:35:57 +08:00
2e9bc16136
emqttd_plugins:init/0
2016-10-02 14:36:54 +08:00
daa87206a7
random
2016-10-01 09:43:21 +08:00
6b3d67c515
fix random:seed/1 warning
2016-09-30 16:13:50 +08:00
f510ab894f
remove is_superuser/2 callback
2016-09-30 10:23:04 +08:00
8d48e8d2e2
Support 'is_superuser/2 callback
2016-09-28 22:45:20 +08:00
d0218deb88
Add hooks: session.created, session.terminated
2016-09-28 22:43:58 +08:00
66ca65733a
emqttd:run_hooks/2, emqttd_hook:run/2
2016-09-23 15:29:12 +08:00
1bb1799d34
local subscription, shared subscription
2016-09-18 14:08:57 +08:00
7d9ad96021
refactor emqttd_conf
2016-09-09 22:52:17 +08:00
61d8b2d907
fixed emqttd_ctl bridges list error
2016-09-09 21:49:57 +08:00
7e41bc9091
improve conf design
2016-09-09 20:30:00 +08:00
edb45d7029
retained_message -> mqtt_retained
2016-09-09 19:38:42 +08:00
5eda6c9dd2
rewrite_subscribe/4, rewrite_unsubscribe/4
2016-09-09 17:37:25 +08:00
66c84aef00
'' -> '%u', '' -> '%c'
2016-09-09 17:00:12 +08:00
6ceb1c6718
Fix subscribe, unsubscribe
2016-09-09 16:34:29 +08:00
bd61ddb03c
map()
2016-09-09 10:48:39 +08:00
5d10a1c224
Merge branch 'emq20' of github.com:emqtt/emqttd into emq20
2016-09-09 10:36:22 +08:00
a677e1628d
rename mqtt_topic
2016-09-08 15:40:35 +08:00
a16802d018
session.subscribed, session.unsubscribed hooks and retainer module
2016-09-08 09:10:45 +08:00
49258f4a0c
Fixing issues in cluster mode.
2016-09-07 15:07:06 +04:30
7a295f614f
Send ClientId, Username as a Tuple in unsubscribe hook
2016-09-03 11:56:42 +04:30
177ae6a71b
Fix unmatching args in mod_rewrite unsubscribe hook
2016-09-03 11:56:28 +04:30
aab2bddeda
fix issue #671 - fix clientid trace
2016-09-02 09:11:55 +08:00
10e9abfdec
fix issue #671 - ~p
2016-09-02 08:39:34 +08:00
19fd92b41b
Send Packet...
2016-08-29 13:57:12 +08:00
d61d2605ad
base62
2016-08-27 15:50:49 +08:00
dbed5b914a
base62
2016-08-27 15:44:22 +08:00
b0f082ebe0
to_hexstr/1, from_hexstr/1
2016-08-23 10:13:13 +08:00
a0e2d2981a
merge mqtt-sn
2016-08-22 17:41:54 +08:00
a1ed02499c
mqtt_topic
2016-08-21 16:21:45 +08:00
0816ec9966
emqttd_app eunit
2016-08-21 14:09:00 +08:00
7206e18621
mqtt_topic
2016-08-21 13:52:53 +08:00
1eaa5bdfa6
tab topic
2016-08-21 13:46:11 +08:00
314aaf536f
add export
2016-08-21 13:13:17 +08:00
8f54572f93
run_hooks client.subscribe.after
2016-08-18 15:54:02 +08:00
354ab5ad21
msgid -> id
2016-08-18 10:57:00 +08:00
6beb6bbbe4
os:timestamp
2016-08-18 10:25:20 +08:00
f2f5f251d7
improve the design of retainer
2016-08-18 08:09:43 +08:00
2b45dbf09f
fix 'undefined' msgid
2016-08-17 13:46:32 +08:00
6d5ce1f584
Merge branch 'emq20' of github.com:emqtt/emqttd into emq20
2016-08-17 12:35:59 +08:00
d72c7ad07c
fix format
2016-08-17 12:35:26 +08:00
b59a1d7547
sender
2016-08-17 08:49:45 +08:00
01cf8b8562
Username
2016-08-16 15:49:00 +08:00
595c0f2d5a
dispatch
2016-08-16 15:38:38 +08:00
ef8006bc89
fix rewrite
2016-08-16 15:23:17 +08:00
e2246c7406
reg_session
2016-08-16 14:43:16 +08:00
d0be556f33
2.0 - improve design of session and hook
2016-08-16 14:29:39 +08:00
c5e88ab1a4
emqttd_ctl eunit
2016-08-15 15:36:52 +08:00
8c1af879d3
emqttd_app eunit
2016-08-15 11:29:12 +08:00
f166143cd0
Don't register name for pool_sup
2016-08-13 12:21:18 +08:00
d8aa7d9cfa
emqttd_bridge_sup_sup
2016-08-13 11:24:06 +08:00
8ca3430e39
improve the design of bridge
2016-08-13 11:03:14 +08:00
bc5cfb4b36
bridge sup
2016-08-13 11:02:39 +08:00
1266b4e860
ack qos
2016-08-12 22:39:13 +08:00
0a967df15a
do_subscribe_/4, do_unsubscribe_/3
2016-08-12 22:23:29 +08:00
6e64686f77
pass test cases first
2016-08-12 16:49:50 +08:00
dd9217bf73
fix cli
2016-08-12 16:26:36 +08:00
9a4c44913e
commen tests
2016-08-12 12:59:03 +08:00
c86aa94ae7
mqtt_subscriber
2016-08-10 22:41:06 +08:00
8a0a7978dd
presence
2016-08-10 22:30:02 +08:00
e2dab894af
emqttd_server:publish/1
2016-08-10 22:22:12 +08:00
0d16f766c3
setstats for mqtt_subscriber
2016-08-10 21:54:02 +08:00
417cb3620d
mqtt_subscriber
2016-08-10 21:50:28 +08:00
d6041395ef
mqtt_session and mqtt_local_session
2016-08-10 21:45:37 +08:00
c67a30bf7b
mqtt_subproperty
2016-08-10 21:38:00 +08:00
38daaa2f5c
server -> pubsub -> router
2016-08-10 21:29:55 +08:00
91e96e738d
emqttd_cm:reg/1, emqttd_cm:unreg/1
2016-08-10 16:40:36 +08:00
766f74692d
mqtt_local_session
2016-08-10 16:36:09 +08:00
162b7ec229
mqtt_pubsub, mqtt_subscription, mqtt_subscriber
2016-08-10 15:41:10 +08:00
6686139bc6
mqtt_trie, mqtt_trie_node
2016-08-10 15:04:26 +08:00
15be2037f3
async_unsubscribe -> unsubscribe
2016-08-10 14:08:46 +08:00
b92231047c
subscriber_down/1
2016-08-10 14:02:13 +08:00
bf8730d12d
{noreply, State}
2016-08-10 12:26:51 +08:00
bba8066639
Dispatcher
2016-08-10 12:18:55 +08:00
078c39232b
dispatcher
2016-08-10 12:12:25 +08:00
33472a7f6e
pubsub and dispatcher
2016-08-10 12:11:52 +08:00
af6c779631
improve the pubsub design
2016-08-09 18:45:47 +08:00
4c4d9a718c
emqttd_router:dump/0
2016-08-08 17:41:48 +08:00
317ce3cfdf
ok
2016-08-08 14:58:49 +08:00
28be1e2a00
Add dispatch/3
2016-08-08 14:34:11 +08:00
bc72e33056
PubSub:init_tabs
2016-08-08 14:14:54 +08:00
b3a48b937f
pubsub_adapter
2016-08-08 14:06:52 +08:00
8b6cc4d5f8
don't create topics
2016-08-08 14:01:49 +08:00
226933018a
improve the design of pubsub and router
2016-08-08 13:49:52 +08:00
e73df7f54f
proc monitor module
2016-08-08 13:46:15 +08:00
37bd5465bd
support local route
2016-08-07 18:09:07 +08:00
285421f073
rm emqttd_backend.erl
2016-08-01 15:07:38 +08:00
f998d2a41d
fix CT errors
2016-07-23 11:10:55 +08:00
3c33bdddc7
list_to_atom
2016-07-22 11:43:40 +08:00
67637408fc
string:tokens/2
2016-07-22 11:41:11 +08:00
3f9de8c073
fix plugins
2016-07-22 11:38:48 +08:00
1bcc2272b5
fix compile warning
2016-07-21 18:29:31 +08:00
3e42f57bc6
2.0 - emqttd:conf/1 to read config
2016-07-21 17:52:08 +08:00
68910aa403
2.0 - gen_conf, gen_logger applications
2016-07-21 17:51:28 +08:00
9555b0bf05
2.0 - support 'cache_acl' option
2016-07-21 17:51:02 +08:00
0dbbe7d0df
2.0 - read config from etc/emqttd.conf
2016-07-21 17:23:34 +08:00
1602b44267
2.0 - gen_conf:value/2 to read config
2016-07-21 17:19:08 +08:00
2370e7dfcb
2.0 - replace 'now/0' with 'erlang:monotonic_time/0'
2016-07-21 17:18:27 +08:00
710890dd22
relx
2016-07-21 09:31:14 +08:00
2e200f253f
2.0 - erlang.mk to replace rebar
2016-07-19 17:46:05 +08:00
03d6710b60
gen_conf to improve the configuration of emqttd broker
2016-07-19 16:49:30 +08:00
ca44fd4031
Merge branch 'master' into plus
2016-07-16 21:56:37 +08:00
61b2ab48ad
merge emq10
2016-07-16 21:55:02 +08:00
9f509c3d13
optimize the procedures that retrieve the Broker version and Borker description in the tick timer
2016-07-15 21:45:58 +08:00
a362b96b6b
add 'bin/emqttd_ctl users list' command
2016-07-06 15:23:45 +08:00
3a43d2b41f
WSLOG
2016-06-30 23:24:02 +08:00
c926964b8c
Merge branch 'master' into emq10
2016-06-30 14:48:07 +08:00
686574913c
fix issue #561 - websocket client's process may leak when no mqtt packets received
2016-06-30 14:40:07 +08:00
02a17a8e96
Add emqttd_ws_client_sup
2016-06-30 14:33:54 +08:00
61a64ea0b0
send(Packet)
2016-06-28 16:44:52 +08:00
842df63605
merge master
2016-06-28 11:27:52 +08:00
2cae8e284a
{simple_one_for_one, 0, 1}
2016-06-27 09:57:07 +08:00
9181c273ed
enhance emqttd_client ratelimit handling
...
This allows rate limits on a client to be queried
and changed dynamically (possibly by plugins), by
exposing additional apis.
`set_rate_limit/2` expects a Ratelimit tuple module of
the form `{module, record}` where module implements
`check(NumBytes, RlTuple) -> {TimeToPause, NewRlTuple}`
It is recommended that the rate limit module also
implement `new` to allow creating new RateLimit records.
See `esockd_ratelimit` for a reference implementation.
2016-06-23 10:34:37 +05:30
b877cec208
Merge branch 'issue#599' into emq10
2016-06-21 11:35:25 +08:00
0aa8a82e59
ensure the mqtt listener is started successfully
2016-06-21 11:33:23 +08:00
fe3becbf9b
Fix issue#599 - Reject empty clientId with non-clean session
2016-06-21 11:29:59 +08:00
83b25fe84a
2.0
2016-06-20 12:18:49 +08:00
bf2e1c39c3
1.1.2
2016-06-18 14:10:22 +08:00
eaf254e919
Merge branch 'master' into plus
2016-06-05 12:51:35 +08:00
0dea9d0bb0
1.1.1
2016-06-05 12:37:19 +08:00
8a908b43d5
Fix the incompatible Qos
2016-06-04 12:07:54 +08:00
faa7ae2886
Fix issue#575
2016-06-01 11:52:21 +08:00
b26455a512
ListenOn
2016-05-27 17:32:34 +08:00
b4ac98f9c2
Merge pull request #568 from emqtt/issue#561
...
GC after a session DOWN
2016-05-26 19:52:02 +08:00
176b0b64ea
GC after a session DOWN
2016-05-26 19:50:08 +08:00
66d4abce14
1.1
2016-05-23 15:21:13 +08:00
40264564af
esockd_cidr
2016-05-23 15:21:04 +08:00
820806d4f0
esockd_cidr
2016-05-23 15:20:56 +08:00
e16f8506ef
base62 encode/decode
2016-05-17 10:36:09 +08:00
c7ecc0ace0
merge emq10
2016-05-07 10:30:22 +08:00
3ef099389a
1.1
2016-05-05 18:18:50 +08:00
6245d24c83
{error, already_existed}
2016-05-05 15:44:36 +08:00
f50efa5813
fix issue#542
2016-05-05 15:36:44 +08:00
dae1cc1f81
1.0.2 release
2016-05-04 01:02:00 +08:00
76851e58fb
atom_to_list(Username)
2016-05-03 18:31:58 +08:00
9b71f9f6c0
new plugin mechanism
2016-05-03 18:02:41 +08:00
3aef962a07
2.0
2016-05-02 22:31:28 +08:00
1e89fcec1e
Merge pull request #537 from emqtt/issue#534
...
Fix issue#534 - Add './bin/emqttd_ctl vm ports' CLI
2016-04-29 00:23:39 +08:00
17d1598688
Fix issue#534 - Add './bin/emqttd_ctl vm ports' CLI
2016-04-29 00:23:57 +08:00
f5adafe9e2
fix issue #535
2016-04-29 00:17:07 +08:00
4d8f7ffb88
1.0.1
2016-04-16 14:38:22 +08:00
a0319d9d26
Fix queue dispatch
2016-04-14 18:23:01 +08:00
31557eba05
1.0
2016-04-13 02:20:44 +08:00
b8a5ff2314
fix issue #503
2016-04-12 20:34:41 +08:00
3733574105
fix issue #500
2016-04-12 15:11:01 +08:00
b257423730
more test cases for parer
2016-04-12 11:19:55 +08:00
fa67becc3b
Merge pull request #499 from callbay/master
...
matches for the remaining length field in the variable header
2016-04-12 10:12:27 +08:00
d6528886cc
matches for the remaining length field in the variable header
2016-04-07 14:33:39 +08:00
a758423a2e
fix issue #486 - gen_server2:call/3 to register a client
2016-03-30 19:33:53 +08:00
4495d61c62
a
2016-03-26 19:01:33 +08:00
fffbd3dd1e
hibernate
2016-03-22 18:14:13 +08:00
e88fe8b6ae
fix issue #479
2016-03-21 10:08:59 +08:00
2a16888f07
0.17.1
2016-03-21 09:54:24 +08:00
467c6307f6
keepalive * 1.25
2016-03-15 00:58:35 +08:00
e08dbf82f6
remove a transaction
2016-03-14 15:48:39 +08:00
9584f2a990
trans, and stats_timer
2016-03-14 15:47:31 +08:00
50a11ce6c9
-spec().
2016-03-14 14:20:10 +08:00
17f40f458f
if_subsciption, async_subscribe
2016-03-14 13:21:35 +08:00
b08bd5a578
retained_message
2016-03-12 16:38:30 +08:00
ba5fcfdfae
merge PR#462
2016-03-12 15:55:17 +08:00
e32d85f40a
backend and retained_message
2016-03-12 15:39:19 +08:00
0a9ecf833a
export_type
2016-03-12 01:11:06 +08:00
72d9ed2024
emqttd:publish|subscribe
2016-03-12 00:30:37 +08:00
978413298d
HTTP Publish: support 'topics' parameter
2016-03-11 23:45:03 +08:00
37fa9a2f9b
return ok | {error, any()}
2016-03-11 23:43:41 +08:00
d9d7581013
0.17.0 - Improve the design of Hook, PubSub and Router
2016-03-11 23:42:37 +08:00
faf05eb85a
test cases for server, pubsub and router
2016-03-11 23:19:17 +08:00
f1f58818d5
backend_subscription
2016-03-08 13:50:41 +08:00
0f1347a495
add 'routes' command, improve usage
2016-03-08 13:28:11 +08:00
fb273f0eca
disc_copies
2016-03-08 13:27:17 +08:00
16d488adca
emqttd:publish/1
2016-03-08 13:26:46 +08:00
26655f1ee3
emqttd:publish/1
2016-03-08 13:25:19 +08:00
73b7de7cb0
emqttd:publish
2016-03-08 13:21:17 +08:00
67f1e15d4a
start_listeners, stop_listeners
2016-03-08 13:20:50 +08:00
ef8cff4cac
emqttd:publish/1
2016-03-08 13:19:03 +08:00
34493b6fec
update PRINT_CMD
2016-03-08 13:17:04 +08:00
52adc66bda
move start_listeners/0, stop_listeners/0 to emqttd_app.erl, add publish/subscribe APIs
2016-03-08 13:15:50 +08:00
9c9633ab27
just to make it more readable
2016-03-05 23:12:25 +08:00
d6b4ff654a
add 'sys' flag to message
2016-03-05 21:16:16 +08:00
652f5f5767
fix issue #450 . Print a hint if the auth_username module is not enabled
2016-03-03 11:12:08 +08:00
cf4dfe632f
Issue #460 - Timer Tick at interval of (Keepalive * 1.5)/2
2016-03-01 18:59:12 +08:00
d1bb0e04fd
fix syntax error
2016-02-28 23:49:10 +08:00
e40775f1f1
fix issue #438
2016-02-21 10:06:14 +08:00
5695ba178c
cli common tests
2016-02-17 23:52:04 +08:00
369c5e86c5
fix issue #438 - Bridge emqttd broker to another emqttd broker & emqttd to mosquitto bridge
2016-02-17 21:15:34 +08:00
955d8e37fd
router_pool/1
2016-02-16 03:03:16 +08:00
757d1f5fc5
Merge branch 'master' into 0.16
2016-02-16 02:56:59 +08:00
6930439158
-compile(export_all)
2016-02-16 02:54:29 +08:00
8ba6c5bbb6
foreach
2016-02-16 02:17:14 +08:00
e605dcb111
fix spec of wildcard/1
2016-02-16 02:16:55 +08:00
87a2f2680c
rm priority flag
2016-02-16 02:16:30 +08:00
3d2cb93ebd
rm -ifdef(TEST)
2016-02-16 02:16:14 +08:00
3561680697
rm lager:error log
2016-02-16 02:15:52 +08:00
9cb0fe3f0a
more test cases
2016-02-14 01:50:51 +08:00
dfdad8bcb6
refactor the router and pubsub
2016-02-14 01:48:49 +08:00
0d21e5c911
fix issue #440 - mqtt_message record: add 'sender' field
2016-02-14 00:35:42 +08:00
150c103cfa
replace emqttd_opts:g/3 with proplists:get_value/3
2016-02-13 18:36:33 +08:00
541af6256d
replace emqttd_opts:g/3 with proplists:get_value/3
2016-02-13 18:36:09 +08:00
49a979a25e
replace emqttd_opts:g/3 with proplists:get_value/3
2016-02-13 18:35:53 +08:00
1b61ef0856
rm g/2, g/3
2016-02-13 18:35:10 +08:00
890de0c60a
is_queue/1, -ifdef(TEST).
2016-02-13 18:34:28 +08:00
3c53cf2b09
merge zenmq_trie, zenmq_mnesia, zenmq_boot
2016-02-13 14:26:40 +08:00
bd1e618cc8
rewrite emqttd_node module
2016-02-11 15:55:10 +08:00
767c4ccc6e
fix issue #449 - Improve the CLI of cluster
2016-02-11 15:54:35 +08:00
44d598fd87
rm reg_name/2, seed_now/0 functions
2016-02-11 15:53:23 +08:00
89052d8e6e
add emqttd_time module, fix comments and format
2016-02-11 15:52:59 +08:00
1560386ab2
Fix delete/1, add lookup/1
2016-02-11 15:42:29 +08:00
3f047a1d16
add emqttd_time module
2016-02-11 14:33:42 +08:00
9dda709aa1
move running_nodes/0 to emqttd_mnesia and improve some functions
2016-02-11 14:31:42 +08:00
a5116c7fa6
emqttd_time to replace emqttd_util
2016-02-11 14:30:08 +08:00
8aad88e825
fix issue #449 - Improve the design of cluster
2016-02-11 01:42:09 +08:00
e030454466
if only one core, the router will not work
2016-02-06 16:35:33 +08:00
94c3e69b44
Licensed under the Apache, Version 2.0
2016-02-05 14:26:17 +08:00
1e852ded91
0.16 - support static subscriptions
2016-02-02 13:36:52 +08:00
5306463b7e
updated copyright
2016-02-01 11:59:44 +08:00
f65676c232
fix plen/2 - return 0
2016-01-25 14:46:30 +08:00
d8c116a502
add now_to_ms/0, now_to_ms/1 functions
2016-01-25 12:59:41 +08:00
83d64308c5
plen/2 spec
2016-01-24 14:15:34 +08:00
8934d8ecad
stop/1, emqttd:seed_now/0
2016-01-24 13:43:42 +08:00
0b686da281
iolist_to_binary(Name)
2016-01-24 13:42:59 +08:00
22a282e39e
emqttd:seed_now/0 to replace random:seed(now())
2016-01-24 13:42:22 +08:00
fb32c509ce
-spec stats/1
2016-01-23 22:52:50 +08:00
4ebdbd75a3
add out/2, plen/1
2016-01-23 22:04:36 +08:00
166e085fff
add client_connected/3
2016-01-21 15:37:25 +08:00
7193bf4f20
rm bin/1
2016-01-21 12:46:43 +08:00
4934bf54c0
add passwd_hash/2 api
2016-01-20 15:38:51 +08:00
b5c514b39c
fix dispatch
2016-01-20 15:38:24 +08:00
284abc7388
fix reverse_route stats
2016-01-17 20:03:47 +08:00
51c5ea1f96
fix route, reverse_route stats
2016-01-17 20:02:44 +08:00
4f9d429478
fix pubsub, sessions, trace commands
2016-01-17 20:02:13 +08:00
a983361121
fix issue#428 - Username/Password Authentication: support to configure default users
2016-01-17 20:01:36 +08:00
1cbdc5e9e4
use emqttd:reg_name/2 to replace name/1
2016-01-17 20:00:46 +08:00
5bfd3a784e
setstats after route table changed
2016-01-17 20:00:23 +08:00
43165a5e8a
use emqttd:reg_name/2 to replace name/1
2016-01-17 19:59:33 +08:00
0a29c8760e
add reg_name/2 function
2016-01-17 19:59:05 +08:00
2544786c56
add_routes([], _Pid)
2016-01-16 10:40:37 +08:00
21cb2bea6e
2016
2016-01-15 13:43:22 +08:00
b46c8d2f0f
Move github wiki to redthedocs
2016-01-14 17:20:01 +08:00
4e474ee8b9
fix issue #427 - Optimization for Route ETS insertion
2016-01-12 14:10:50 +08:00
3745d7a24b
router pool sup
2016-01-12 14:09:31 +08:00
ba5541c768
Move the aging code to router
2016-01-12 14:02:21 +08:00
20ede24d83
fix issue #427 - Optimization for Route ETS insertion
2016-01-12 14:01:28 +08:00
6e3ae6412d
-type topic() :: binary().
2016-01-12 13:58:24 +08:00
78f2a83a82
0.15
2016-01-07 13:21:14 +08:00
1809d0960d
~p
2016-01-02 17:01:24 +08:00
32b1448204
0.14.1
2015-12-28 20:20:24 +08:00
4a175bfc68
fix spec
2015-12-28 20:18:31 +08:00
4ec480af0b
fix spec
2015-12-28 20:17:18 +08:00
e6e77953f1
delete
2015-12-27 21:56:31 +08:00
2dd8c3d778
remove trap_exit flag, and fix issue #413
2015-12-23 23:20:05 +08:00
78dd1f8838
fix issue #413
2015-12-23 22:33:49 +08:00
6ec5eccd69
fix issue #411
2015-12-17 17:30:49 +08:00
be390d42ac
stop
2015-12-17 14:12:45 +08:00
7ffa25c655
destroy
2015-12-17 14:12:35 +08:00
fe82fde717
subscription
2015-12-17 12:38:13 +08:00
e37b00a9e4
fix subscriptions cli
2015-12-16 11:04:51 +08:00
7cd5367f3b
binary
2015-12-16 11:04:20 +08:00
d3ee464789
topics, subscriptions
2015-12-16 10:22:37 +08:00
b172a78fcd
lookup/2, tune_qos
2015-12-16 10:18:28 +08:00
787a427fda
fix load/1 return
2015-12-10 21:30:26 +08:00
ab556b6bda
rm subscriptions from sess_info
2015-12-10 16:49:58 +08:00
11bdcf1017
fix already_exists
2015-12-10 15:55:24 +08:00
2dd6d160f3
format
2015-12-10 15:04:13 +08:00
26893c764c
serilize
2015-12-10 14:09:05 +08:00
e1e09599ef
Merge branch '0.14' of github.com:emqtt/emqttd into 0.14
2015-12-09 15:41:37 +08:00
05bf24b33b
serializer
2015-12-09 15:41:03 +08:00
00f362fabc
publish(To, ...
2015-12-07 21:35:06 +08:00
3a8ada21e0
dispatch
2015-12-07 21:30:58 +08:00
3d8e91bc20
comment io:format
2015-12-07 21:30:45 +08:00
9e0fe19c25
qos
2015-12-07 21:20:35 +08:00
fd6a350d9c
dispatch
2015-12-07 21:19:12 +08:00
df5daaac5b
dispatch
2015-12-07 21:17:30 +08:00
af02965555
comment start_tracelog
2015-12-07 18:38:07 +08:00
fe69fd95c8
{read_concurrency, true}
2015-12-07 17:12:45 +08:00
4cde27d724
read_concurrency
2015-12-07 14:33:23 +08:00
8f22b0ffbc
route
2015-12-07 00:22:40 +08:00
f4d09c973d
remove mnesia index
2015-12-06 20:32:03 +08:00
c29fd68dd5
storage_properties
2015-12-06 20:30:59 +08:00
a261f3c678
emqtt log
2015-12-06 12:03:05 +08:00
17896c7e77
fix issue #161 - Feature Request - Log Topics
2015-12-06 11:28:05 +08:00
b0ada8ae56
fmt
2015-12-05 20:06:41 +08:00
e3cd170683
0.14
2015-12-05 15:43:49 +08:00
855152f653
spec/1
2015-12-05 02:18:06 +08:00
0c13490092
os:timestamp
2015-12-05 02:13:22 +08:00
1ca477ffa1
monitors
2015-12-05 02:12:27 +08:00
d6a528e0f7
0.14 refactor
2015-12-04 23:53:42 +08:00
812779004f
new pubsub
2015-12-04 17:36:09 +08:00
cfaa0c5e40
0.14
2015-12-03 22:28:39 +08:00
4deb96dc91
0.14
2015-12-03 21:17:07 +08:00
86460cdebc
0.14
2015-12-03 21:15:25 +08:00
392b008a43
TODO: subscriptions
2015-12-03 13:14:32 +08:00
80117c1e8a
rewrite pubsub, router
2015-12-03 12:56:13 +08:00
db8b7c9d82
0.14
2015-12-02 18:01:51 +08:00
16f23406a4
0.14
2015-12-02 18:01:26 +08:00
0b1540f1db
comment process_flag(priority, high)
2015-11-28 11:26:53 +08:00
e78d4fc39b
fix issue #383
2015-11-27 22:36:12 +08:00
df8414dbdc
0.13.1
2015-11-27 21:01:18 +08:00
2d1066517f
Msg =
2015-11-14 14:44:25 +08:00
e05f0cb5b1
Merge pull request #382 from emqtt/chat
...
QOS0/1/2, Pooler Error
2015-11-14 10:46:45 +08:00
860183f931
chat
2015-11-12 13:07:46 +08:00
9effc2fad7
monitors
2015-11-11 12:18:13 +08:00
4fb018203e
fix issue #377
2015-11-11 09:46:23 +08:00
7d54cd8e5d
rate limit log
2015-11-08 14:42:38 +08:00
e25856e9a1
fix issue #374
2015-11-07 23:09:31 +08:00
21a5f3ee33
hibernate
2015-11-07 22:45:57 +08:00
64a34b216c
format
2015-11-07 20:46:31 +08:00
bdea67cf2c
Merge pull request #371 from emqtt/0.13
...
fix issue #357 - Cannot kick transient client out when clientId colli…
2015-11-06 21:31:12 +08:00
59b401c506
fix issue #357 - Cannot kick transient client out when clientId collision
2015-11-06 21:26:46 +08:00
38fb211719
Merge branch 'master' of github.com:emqtt/emqttd
2015-11-06 12:30:27 +08:00
d227ba3ced
warning
2015-11-06 12:30:07 +08:00
4e0220ae81
ok
2015-11-05 12:40:06 +08:00
22889f552c
fix issue #163 - Protocol Compliant - Session Present Flag
2015-11-05 12:29:29 +08:00
8491467bbb
support 'and', 'or'
2015-11-04 21:42:17 +08:00
d09721301e
conflict
2015-11-04 10:22:49 +08:00
9bad2bf65b
support Seq
2015-11-03 12:52:27 +08:00
ea564ec8ef
mod
2015-11-02 20:34:23 +08:00
ecc0f052ef
reply
2015-11-02 15:51:34 +08:00
cff4ca0296
vsn
2015-11-02 15:51:24 +08:00
3c69d1a5c1
fix log
2015-11-02 15:00:43 +08:00
83d4801fe8
disc_copies
2015-11-01 20:45:13 +08:00
4b26291cb9
client(State)
2015-11-01 20:44:21 +08:00
c7f0e33674
rate limit
2015-11-01 16:03:32 +08:00
cf95c5e1b9
0.13 refactor
2015-10-31 18:43:04 +08:00
3f41a6c241
peername
2015-10-31 15:08:25 +08:00
f9027ed1f4
fix issue #367 - Fix the order of emqttd_app:start_server/1
2015-10-31 15:07:50 +08:00
b9962d697c
0.13.0
2015-10-30 21:23:17 +08:00
4ed62d018e
refactor log
2015-10-30 21:20:37 +08:00
19930b6382
refactor protocol
2015-10-30 18:00:23 +08:00
f6636a9783
refactor client
2015-10-30 16:03:25 +08:00
f4cf90ae91
refactor client
2015-10-30 16:00:11 +08:00
565c8abb3a
improve suback
2015-10-26 16:30:39 +08:00
47710c36aa
port_command
2015-10-26 09:25:57 +08:00
976c7653f3
use esockd_rate_limiter
2015-10-26 09:25:40 +08:00
f58f42196a
0.12.4
2015-10-26 09:21:24 +08:00
2af91ea140
link with client
2015-10-26 09:21:03 +08:00
fb9f1bf8e4
rate_limit
2015-10-26 09:20:13 +08:00
59ca283eb0
gen_server
2015-10-23 18:06:35 +08:00
fd7276c587
0.12.3
2015-10-22 10:31:29 +08:00
8bddc3e327
comment binary
2015-10-22 10:31:03 +08:00
52d63125d3
improve log and fix issue #353
2015-10-21 21:36:56 +08:00
86ea9c844f
fix issue #350
2015-10-21 21:18:36 +08:00
7530bfb5fa
ets:insert
2015-10-19 09:45:36 +08:00
6faf488701
ets:insert
2015-10-19 09:45:31 +08:00
67ebff26ce
0.12.2
2015-10-16 15:07:25 +08:00
a35d51ea24
fix issue #346
2015-10-16 14:58:51 +08:00
fae3e1e32f
AckFun
2015-10-15 18:59:51 +08:00
221124d7b2
fix issue #266 - will not count publish
2015-10-14 19:07:41 +08:00
e3b5c6be4e
PUBLISH_PACKET
2015-10-14 18:56:43 +08:00
3dd42b65cf
/status
2015-10-13 23:03:02 +08:00
a16e527975
0.12.1 refactor
2015-10-13 21:09:13 +08:00
05ff1ab002
gen_event
2015-10-13 21:08:56 +08:00
ebf203a931
refactor metrics
2015-10-13 21:05:11 +08:00
6a66ca90b1
concat
2015-10-13 21:04:15 +08:00
5daeac083c
spec
2015-10-13 21:03:25 +08:00
43523f2a1c
received/sent metrics
2015-10-13 21:03:01 +08:00
d3e39ae9a3
src/emqttd_mod_rewrite.erl
2015-10-13 21:01:53 +08:00
a055a0a0c8
IS_PUBSUB
2015-10-13 20:56:10 +08:00
192dc85304
id
2015-10-13 20:55:33 +08:00
063f59f846
fix process_info
2015-10-12 21:07:05 +08:00
d4a434176a
sysmon
2015-10-12 21:06:47 +08:00
6209d47aae
name
2015-10-12 21:06:18 +08:00
4825591565
name
2015-10-12 21:06:01 +08:00
deaf220343
sysmon
2015-10-12 21:05:37 +08:00
47e3e826dc
0.12.1
2015-10-12 21:03:01 +08:00
20cfc2754c
broker
2015-10-11 21:10:47 +08:00
8eb54cc2c3
fix issue #68 - /# topics will not match #, +/#
2015-10-11 15:27:56 +08:00
87b5245494
rm space
2015-10-11 04:02:33 +08:00
13001396de
cli
2015-10-11 03:03:07 +08:00
b9b75fdb65
add 'dist' module
2015-10-11 02:48:32 +08:00
6bc3e70f46
export node_name/1
2015-10-10 20:12:24 +08:00
7af13af848
warning
2015-10-10 19:56:43 +08:00
aad1f3547f
allow to override command
2015-10-10 19:47:38 +08:00
b59a8664eb
fix issue #282 - emqttd_sm optimized
2015-10-10 14:32:33 +08:00
f57e6b43db
critical -> error
2015-10-10 13:36:06 +08:00
fa84a2595b
critical -> error
2015-10-10 13:30:50 +08:00
1935b414c7
issue #282 - improve sm
2015-10-10 13:12:00 +08:00
d63f043566
fix timer
2015-10-10 11:53:31 +08:00
5977c44996
fix issue #182 - etained message expiration
2015-10-10 00:04:07 +08:00
0a5d1f9e3e
{local, ?MODULE}
2015-10-10 00:01:07 +08:00
24336d006f
0.12.0
2015-10-08 14:54:31 +08:00
d5a400c308
fix issue #292 - async sub/unsub
2015-10-04 19:48:50 +08:00
78288e8088
improve keepalie
2015-10-04 19:43:58 +08:00
a6770e3727
mnesia
2015-10-01 16:10:21 +08:00
1fab8084e1
rm cli
2015-10-01 11:23:37 +08:00
354ae6f398
sort
2015-10-01 11:23:24 +08:00
14d2de3b05
MODUEL as pool name
2015-10-01 11:22:57 +08:00
e7b6778a43
rm cli
2015-10-01 11:22:33 +08:00
d7ca17b336
dump
2015-10-01 11:22:18 +08:00
af14bf9329
rm cli
2015-10-01 11:22:01 +08:00
b946f3df9b
new ctl
2015-10-01 11:21:43 +08:00
dcca96b6ae
MODULE as pool name
2015-10-01 11:21:27 +08:00
95928f6f75
rm cli
2015-10-01 11:20:41 +08:00
b539a719a8
rm cli
2015-10-01 11:20:22 +08:00
bafff792fa
useradd, userdel cli
2015-10-01 11:20:01 +08:00
d3ce7dcae1
emqttd_ctl
2015-10-01 11:19:24 +08:00
91bd0c654c
cli
2015-10-01 11:17:35 +08:00
e09148b040
cli
2015-09-30 03:06:17 +08:00
470d5644ef
priority, high
2015-09-29 17:31:10 +08:00
f15e8bc630
print ack timout
2015-09-29 12:10:55 +08:00
f57affa2b3
fix MFArgs
2015-09-29 11:27:48 +08:00
86a1f7f7d4
fix issue #264
2015-09-29 10:10:30 +08:00
dfc3194d53
env
2015-09-29 10:09:21 +08:00
23095af55f
fix issue #318
2015-09-28 21:45:44 +08:00
d7cdc477b4
fix issue #311
2015-09-24 22:38:08 +08:00
4df2e5b552
0.11.0
2015-09-22 14:51:08 +08:00
ba9534a683
fix issue #306
2015-09-21 21:11:42 +08:00
fddbdd1bb9
copy schema
2015-09-19 11:42:36 +08:00
22170b6c6d
timer:seconds
2015-09-19 09:47:17 +08:00
4c8b18389f
Merge pull request #301 from emqtt/dev-feng
...
Fix issue #284
2015-09-18 10:42:30 +08:00
7e06163587
Merge pull request #300 from emqtt/issue#292
...
Issue#292
2015-09-18 10:32:07 +08:00
74d0ef9a95
fix issue #297 - support variable
2015-09-18 10:09:10 +08:00
107c317e11
10000
2015-09-16 22:19:02 +08:00
3e899ab7a2
fix issue #284 - the stupid list_to_atom...
2015-09-16 22:11:17 +08:00
12b4bc9697
misc
2015-09-16 21:52:18 +08:00
9c53d2d3ba
session/1 api
2015-09-16 00:05:48 +08:00
ea70389cf7
ignore duplicated subscriptions
2015-09-11 14:18:30 +08:00
ac9eb43e5e
0.10.4
2015-09-11 10:50:08 +08:00
6a1159ed3f
SESSION_TIMEOUT
2015-09-10 16:17:26 +08:00
fa25d60893
fix issue#280
2015-09-10 11:18:30 +08:00
e6f358a6dd
warning
2015-08-31 13:19:59 +08:00
587cf4609a
0.10.3
2015-08-30 10:38:07 +08:00
5117d88b7a
warning
2015-08-30 10:23:26 +08:00
35bc96807e
Merge branch 'master' into dev-feng
2015-08-27 19:54:26 +08:00
07b717104b
emqttd_ws_client:subscribe/2 api
2015-08-26 21:47:21 +08:00
0f73dbf4a8
0.10.2
2015-08-25 23:44:40 +08:00
4698d040fd
fix issue #262
2015-08-25 13:49:28 +08:00
b08c39db52
stop_listeners
2015-08-24 22:20:32 +08:00
741ebf2ae1
cannot stop emqttd
2015-08-24 22:04:14 +08:00
ad1f3ca44a
add emqttd_client:subscribe/1 api. noreply/1 to hibernate
2015-08-20 19:00:01 +08:00
6d4351e8a9
priority
2015-08-18 18:59:14 +08:00
f9eeab89a2
fix gen_server2 issue, https://github.com/rabbitmq/rabbitmq-server/issues/268
2015-08-16 22:01:04 +08:00
24512a1c1d
gen_server2
2015-08-16 11:06:47 +08:00
2f1c03a469
misc fix
2015-08-16 00:36:56 +08:00
27336f9859
timestamp
2015-08-16 00:12:36 +08:00
768bc2ed1d
hibernate
2015-08-15 23:33:51 +08:00
df43214233
comment log
2015-08-15 22:31:29 +08:00
94442c270f
fix issue #212
2015-08-15 20:42:12 +08:00
aed4834aa7
comment 'inflight queue is full'
2015-08-15 11:15:36 +08:00
4c2e3e93e5
message_dropped
2015-08-14 16:00:38 +08:00
d23bf74d1e
fix issue #244
2015-08-14 12:16:41 +08:00
0232690907
Merge pull request #242 from emqtt/dev-hd
...
get_system_info
2015-08-14 10:31:45 +08:00
5d51d55533
log
2015-08-13 22:29:32 +08:00
cdf981e3c6
get_system_info
2015-08-13 19:18:56 +08:00
91ff959770
Merge pull request #241 from emqtt/issue#231
...
Issue#231
2015-08-13 17:25:52 +08:00
506dc0bd06
Add headers to mqtt_client
2015-08-13 13:01:06 +05:30
e4d45c4105
TODO
2015-08-12 00:26:28 +08:00
c4a09f97d5
fix issue #238 - emqttd_broker:unhook/2 cannot work
2015-08-12 00:26:10 +08:00
bb02ced4f2
fix issue #231
2015-08-11 00:14:07 +08:00
f94755166f
lowercase
2015-08-10 22:36:13 +08:00
3e1f8f8158
sm
2015-08-10 20:09:14 +08:00
5a612657be
session
2015-08-10 12:48:28 +08:00
049f1f1173
setstats
2015-08-10 00:28:24 +08:00
d35be39df7
session statistics
2015-08-10 00:25:11 +08:00
008f48ce43
comment
2015-08-09 12:06:02 +08:00
0f06fdd1c4
0.10.0
2015-08-08 19:33:14 +08:00
0f602d67ba
fix plugins code bug
2015-08-08 18:47:04 +08:00
c6ccacd990
plugins
2015-08-07 17:24:03 +08:00
7ba5772264
temporary
2015-08-05 15:39:29 +08:00
1a64e4e373
plugins
2015-08-04 13:21:59 +08:00
793f17f408
Merge branch 'dev' of github.com:emqtt/emqtt into dev
2015-08-04 11:40:24 +08:00
f0109c7af7
plugin
2015-08-04 11:39:30 +08:00
bf75dbf794
sync with mac air
2015-08-04 09:11:18 +08:00
dd1d48360d
rm apps
2015-08-04 09:10:54 +08:00
c0d9354932
plugins
2015-08-02 21:52:11 +08:00
48534df6c0
comment 'min_heap_size'
2015-08-01 21:00:40 +08:00
0cef1a3096
running_nodes
2015-07-30 00:15:40 +08:00
d52dcd94d5
Merge branch 'dev' of github.com:emqtt/emqtt into dev
2015-07-28 11:24:51 +08:00
b701c9ec4f
try ... catch
2015-07-28 11:22:10 +08:00
ca075f8f21
pick_worker
2015-07-28 11:05:50 +08:00
c276b6c6d1
QOS_I
2015-07-28 10:52:10 +08:00
0c5594bfcf
rm 'and comp
2015-07-27 13:48:54 +08:00
12b5722369
Merge branch 'dev' of github.com:emqtt/emqtt into dev
2015-07-27 13:42:06 +08:00
cefff9c0eb
misc
2015-07-27 13:41:47 +08:00
e370e18b19
subscribe/2
2015-07-25 14:34:44 +08:00
90b3344db0
bridges command
2015-07-25 14:34:25 +08:00
d81946b0d6
0.9.3
2015-07-25 14:34:11 +08:00
8c7d2ebe1c
0.9.3
2015-07-25 14:34:02 +08:00
98250313ab
fix issue #206
2015-07-25 14:16:36 +08:00
268fcace65
mqueue
2015-07-25 10:47:06 +08:00
c65d047fda
QOS_I
2015-07-23 16:04:21 +08:00
ffefcb6b17
Merge branch 'dev-hd' into dev
2015-07-20 08:34:05 +08:00
4278bd9db4
0.9.2
2015-07-19 09:47:29 +08:00
a43c9b3505
node api
2015-07-17 19:29:26 +08:00
cd147c453f
fix issue #196
2015-07-16 17:06:15 +08:00
5c46004c18
hooks
2015-07-16 15:55:58 +08:00
eb097c1056
fix issue #193
2015-07-14 17:55:52 +08:00
c63c74a18f
blank
2015-07-14 17:46:29 +08:00
b6121f6bcb
plain
2015-07-13 08:46:57 +08:00
da560798d1
0.9.1
2015-07-10 10:57:45 +08:00
e59232c2ab
fix issue #189 - Websocket(SSL) cannot work for emqttd_net:peername error
2015-07-10 10:48:09 +08:00
92b6bb4493
0.9.0
2015-07-09 10:17:26 +08:00
0b12082256
hibernate
2015-07-09 10:08:35 +08:00
711a875e23
misc
2015-07-08 22:12:33 +08:00
630dd4f089
https listener
2015-07-08 22:02:00 +08:00
c85617c080
distributed session
2015-07-08 18:17:48 +08:00
fcc0bb98e2
fix issue #184
2015-07-07 15:36:34 +08:00
ed81eb5a9d
'client.acked' hook
2015-07-06 15:26:30 +08:00
4f20f9691a
set_flag
2015-07-06 15:25:03 +08:00
949b70f277
subscribe, unsubscribe hooks
2015-07-06 14:07:24 +08:00
988e61708d
fix session stats
2015-07-06 00:29:08 +08:00
dcc378150d
infinity
2015-07-05 23:57:27 +08:00
d6ea474810
comment
2015-07-05 22:53:54 +08:00
4808cf31b5
vm
2015-07-05 21:00:12 +08:00
a68fa754fe
Merge branch 'dev-hd' into dev
2015-07-05 20:52:34 +08:00
1e86f7bc42
os:timestamp
2015-07-05 20:29:04 +08:00
895c9ddaed
emqttd_message:make, hooks
2015-07-05 20:18:37 +08:00
4ff7f9b2fe
global unique id
2015-07-05 20:15:53 +08:00
87dafdd7b2
client_id
2015-07-02 23:22:27 +08:00
1dcf892a69
vm
2015-06-26 15:03:00 +08:00
288973aabb
State =
2015-06-26 10:29:57 +08:00
8ea0707684
fix session
2015-06-24 22:48:35 +08:00
d09a0787ea
fix sessions
2015-06-24 22:05:00 +08:00
0f68186472
mqueue test
2015-06-24 09:26:22 +08:00
eeee584fef
add 'clientid'
2015-06-24 03:07:59 +08:00
b4080a0adf
ts
2015-06-24 02:51:56 +08:00
82bd645d7a
fix session issue
2015-06-24 01:56:44 +08:00
d0429f56e7
fix 'loads/0' export
2015-06-24 00:38:15 +08:00
89c939b321
{subscribe, TopicTable}
2015-06-24 00:37:58 +08:00
34fc0fb157
now_to_secs
2015-06-24 00:37:41 +08:00
2ff78d7fc6
alarm
2015-06-24 00:37:02 +08:00
7e97e39bd1
etc/plugins.config
2015-06-23 12:46:51 +08:00
3e5675cc71
ipaddress
2015-06-23 12:20:41 +08:00
8702ab838c
0.9 project structure
2015-06-22 16:18:33 +08:00
3a6ed9a876
0.2 project structure
2014-12-06 19:12:29 +08:00
109e98d80c
change heap size
2014-12-02 22:53:29 +08:00
c12a0b236e
add monitor
2014-12-01 22:54:48 +08:00
acc491c799
uupdate go timeout
2014-12-01 17:15:02 +08:00
34bcd2b2db
test
2014-08-19 16:05:21 +08:00
13bf396306
fix issue#18
2013-11-05 00:21:30 +08:00
1f1099e667
add appmon
2013-10-31 17:36:40 +08:00
3e3dfe3fa2
fix client
2013-09-17 11:25:27 +08:00
fd711f3fbc
trie delete
2013-08-23 14:38:28 +08:00
570ca1aa78
fix issue#17
2013-07-16 14:39:38 +08:00
9bdbb84ed2
refactor header file
2013-06-28 11:01:23 +08:00
860532fc68
fix unsubscribe 'error topics'
2013-03-18 15:18:25 +08:00
3626979e31
0.1.5 bug fix
2013-01-05 16:21:37 +08:00
3979c83550
vsn 0.1.4
2013-01-04 16:36:03 +08:00
ba5e21278e
fix qos_2 subscribe
2013-01-04 16:29:35 +08:00
97d27e2456
fix qos_2 bugs
2013-01-04 13:24:18 +08:00
8b85ce4278
add publish/1 api
2013-01-03 21:03:00 +08:00
2c8bb114f9
fix qos_2 message flow
2013-01-03 20:30:07 +08:00
31c687f26c
support trie topic structure
2013-01-01 20:16:02 +08:00
6d795c7273
add license
2012-12-27 21:55:41 +08:00
dbad1cf920
fix cluster
2012-12-27 16:51:32 +08:00
58b1e258c1
add folder
2012-12-27 16:42:59 +08:00
52cca0a908
vsn 0.1.2
2012-12-26 15:38:16 +08:00
69b9e74a94
use ?INFO to print log
2012-12-26 15:25:27 +08:00
e7ba96b263
fix ctl api
2012-12-26 14:36:39 +08:00
ea1e3c59a0
vsn 0.1.1
2012-12-24 17:16:37 +08:00
76169eb446
support topic cluster
2012-12-24 16:59:12 +08:00
c082cbb27b
fix topic record
2012-12-24 11:59:02 +08:00
cd1e2c73d2
support client registry
2012-12-23 17:55:10 +08:00
8fa63244bb
fix issue#3 'PUBLISH' RETAIN
2012-12-23 16:53:38 +08:00
7117d03a09
support keep alive
2012-12-23 16:14:02 +08:00
a8e860b07d
fix .app.src
2012-12-22 18:03:28 +08:00
c1b9449c53
fix sub/pub
2012-12-22 17:35:28 +08:00
425bc2157e
add auth support
2012-12-22 16:42:32 +08:00
87db1acf2b
rm tmp
2012-12-22 14:28:29 +08:00
92ce6ef539
merge emqtt_processor to emqtt_client
2012-12-22 14:28:04 +08:00
0953344e06
fix status
2012-12-21 17:36:32 +08:00
efc1d9f424
add bin/ and some files
2012-12-21 17:33:21 +08:00
6245fb4aa9
first workable
2012-12-21 13:24:48 +08:00
fcb5ac6df3
add mqtt frame
2012-12-21 11:30:35 +08:00
0fabf9feb2
tcp options
2012-12-20 17:35:02 +08:00
cc67e10e69
fix client
2012-12-20 16:44:57 +08:00
a77bbf33e2
first workable
2012-12-20 16:30:51 +08:00
bac534c8c8
fix router
2012-12-19 13:45:04 +08:00
cb04c9c7e5
add file
2012-12-19 13:42:03 +08:00
Feng Lee