Ivan Kozlovic 4cc2677573 MQTT: delete the session record even on restart with clean flag ...

When a session record exists and is currently not connected, if
the user reconnects with the same client ID but with now the
clean flag set, we are required to clear the state. In earlier
implementation (where we were using a stream per session), we
were not deleting the stream to be created right away. Since now
we just have a message per session, it is ok to delete that
message when clearing the existing session that is going to be
replaced.

Also made apiDispatch execute in place for any connection that
is not ROUTER or GATEWAY.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>

2021-09-14 16:33:48 -06:00

..

configs

[fixed] tls timeout now accepts units

2021-07-19 11:42:28 -04:00

pse

Remove external dependency on 'ps' for memory and cpu usage.

2021-06-06 11:13:32 -07:00

sysmem

…

accounts_test.go

Review comments

2021-07-22 11:27:34 -04:00

accounts.go

Use a better seed for a rand generator

2021-08-26 15:16:22 -06:00

auth_test.go

Run gofmt -s to simplify code

2021-04-09 15:18:06 -07:00

auth.go

Adding counter for number of failed logons due to pinned accounts

2021-08-23 18:56:56 -04:00

ciphersuites.go

…

client_test.go

Set defaultServerOptions port to -1 for random

2021-09-02 14:22:56 -06:00

client.go

[ADDED] Monitoring: ClientID (for MQTT clients) on connection events

2021-09-09 13:34:46 -06:00

closed_conns_test.go

System Account on by default.

2020-05-29 17:56:45 -07:00

config_check_test.go

[FIXED] Report config error if "token" defined for cluster{} and gateway{}

2021-09-13 10:21:00 -06:00

const.go

Bump version

2021-09-13 18:41:12 -07:00

consumer.go

Fixed a bug when an interest retention stream with noack consumers is in clustered mode.

2021-09-08 15:02:09 -07:00

dirstore_test.go

[FIXED] MQTT: asset placement in origin cluster

2021-04-28 19:28:00 -06:00

dirstore.go

Make sure jwt claim update does not wipe system imports

2021-08-17 10:03:30 -07:00

disk_avail_openbsd.go

with 'go fmt' applied

2021-08-26 16:52:43 +02:00

disk_avail_windows.go

Separate out disk available for Windows

2020-10-31 12:56:27 -07:00

disk_avail.go

with 'go fmt' applied

2021-08-26 16:52:43 +02:00

errors_gen.go

attempt to improve UX of the error system

2021-08-10 16:08:28 +02:00

errors_test.go

…

errors.go

richer api errors proposal

2021-05-26 08:04:50 +02:00

errors.json

We use u16 to encide header len when replicating JetStream messages.

2021-09-13 18:13:07 -07:00

events_test.go

If we are in a simple mixed-mode setup with just global account and system account and clustered, allow pass through.

2021-08-26 09:41:01 -07:00

events.go

Changed ClientID to MQTTClient and client_id to mqtt_client

2021-09-09 14:34:54 -06:00

filestore_test.go

Fix for issue #2488.

2021-09-09 09:53:22 -07:00

filestore.go

During compaction the cache may not be loaded completely if msg block was lmb (active writing).

2021-09-13 14:36:50 -07:00

fuzz.go

Change naming in server fuzzer

2021-07-23 10:19:07 +01:00

gateway_test.go

Set defaultServerOptions port to -1 for random

2021-09-02 14:22:56 -06:00

gateway.go

Remove the swapping of accounts during processing of service imports.

2021-07-26 07:57:10 -07:00

jetstream_api.go

MQTT: delete the session record even on restart with clean flag

2021-09-14 16:33:48 -06:00

jetstream_cluster_test.go

We use u16 to encide header len when replicating JetStream messages.

2021-09-13 18:13:07 -07:00

jetstream_cluster.go

We use u16 to encide header len when replicating JetStream messages.

2021-09-13 18:13:07 -07:00

jetstream_errors_generated.go

We use u16 to encide header len when replicating JetStream messages.

2021-09-13 18:13:07 -07:00

jetstream_errors_test.go

attempt to improve UX of the error system

2021-08-10 16:08:28 +02:00

jetstream_errors.go

attempt to improve UX of the error system

2021-08-10 16:08:28 +02:00

jetstream_events.go

add domain in JS advisories

2021-05-07 19:35:46 +02:00

jetstream_test.go

Added ability to check if no message exists as a test to store the message.

2021-09-09 11:41:23 -07:00

jetstream.go

Additional lock inversion between jetStream and jsAccount

2021-08-31 14:18:31 -06:00

jwt_test.go

[FIXED] Account resolver TLS configuration

2021-09-02 09:13:54 -06:00

jwt.go

[added] operator option to ensure user are signed by certain accounts

2021-08-23 13:45:11 -04:00

leafnode_test.go

Set defaultServerOptions port to -1 for random

2021-09-02 14:22:56 -06:00

leafnode.go

Make sure to suppress dupes on JS deny all for system account

2021-09-08 17:09:25 -07:00

log_test.go

Check errors when removing test directories and files

2021-04-07 11:09:47 -07:00

log.go

JetStream Clustering WIP

2021-01-14 01:14:52 -08:00

memstore_test.go

JetStream Clustering WIP

2021-01-14 01:14:52 -08:00

memstore.go

Consumer num pending fixes for multiple matches and merging.

2021-08-24 07:52:29 -07:00

monitor_sort_opts.go

…

monitor_test.go

Set defaultServerOptions port to -1 for random

2021-09-02 14:22:56 -06:00

monitor.go

Changed ClientID to MQTTClient and client_id to mqtt_client

2021-09-09 14:34:54 -06:00

mqtt_test.go

Changed ClientID to MQTTClient and client_id to mqtt_client

2021-09-09 14:34:54 -06:00

mqtt.go

MQTT: delete the session record even on restart with clean flag

2021-09-14 16:33:48 -06:00

nkey_test.go

Check errors when removing test directories and files

2021-04-07 11:09:47 -07:00

nkey.go

[added] support for StrictSigningKeyUsage and updated jwt library (#1845)

2021-01-26 17:49:58 -05:00

norace_test.go

During compaction the cache may not be loaded completely if msg block was lmb (active writing).

2021-09-13 14:36:50 -07:00

ocsp.go

Set defaultServerOptions port to -1 for random

2021-09-02 14:22:56 -06:00

opts_test.go

[added] operator option to ensure user are signed by certain accounts

2021-08-23 13:45:11 -04:00

opts.go

[FIXED] Report config error if "token" defined for cluster{} and gateway{}

2021-09-13 10:21:00 -06:00

parser_test.go

[CHANGED] Enforce max_control_line for client connections only

2021-01-26 15:33:39 -07:00

parser.go

[adding] kind and client_type to account connect/disconnect events (#2351)

2021-07-07 17:43:50 -04:00

ping_test.go

Fixed TestPing test

2020-06-12 10:03:47 -06:00

raft.go

During peer removal, try to remap any stream or consumer assets.

2021-09-06 17:29:45 -07:00

reload_test.go

[FIXED] Account resolver TLS configuration

2021-09-02 09:13:54 -06:00

reload.go

fix daisy chained leaf node subject propagation issue. (#2468)

2021-08-25 18:10:09 -04:00

ring_test.go

…

ring.go

…

route.go

fix daisy chained leaf node subject propagation issue. (#2468)

2021-08-25 18:10:09 -04:00

routes_test.go

Set defaultServerOptions port to -1 for random

2021-09-02 14:22:56 -06:00

sendq.go

We should not sit in place here, no measurable effect on latency in tests

2021-07-01 14:29:09 -07:00

server_test.go

Force server name to be set if mqtt{} defined

2021-05-05 13:17:53 -06:00

server.go

If we are in a simple mixed-mode setup with just global account and system account and clustered, allow pass through.

2021-08-26 09:41:01 -07:00

service_test.go

Return not ready for connection reason

2021-04-20 11:45:08 -07:00

service_windows.go

…

service.go

…

signal_test.go

Check errors when removing test directories and files

2021-04-07 11:09:47 -07:00

signal_windows.go

Handle SIGTERM on windows

2021-09-01 14:55:26 -07:00

signal.go

Make SIGTERM exit 1

2021-04-12 10:17:13 -07:00

split_test.go

…

store.go

[CHANGED] ConsumerInfo's SequencePair replaced with SequenceInfo

2021-08-23 12:28:23 -06:00

stream.go

Merge pull request #2526 from nats-io/issue-2525

2021-09-14 06:41:18 -07:00

sublist_test.go

Add in DeliverGroup to consumer as optional queue group.

2021-08-13 15:07:56 -07:00

sublist.go

fixed queue group memory leak

2021-09-13 15:22:05 +03:00

test_test.go

[IMPROVED] MQTT stream per session replaced with single stream

2021-09-08 16:32:41 -06:00

trust_test.go

Check errors when removing test directories and files

2021-04-07 11:09:47 -07:00

util_test.go

unexported import of Comma function from humanize

2020-05-19 14:16:03 -07:00

util.go

Inhibit Go's default TCP keepalive settings for NATS (#1562)

2020-08-14 13:37:59 -04:00

websocket_test.go

[FIXED] Websocket: possible panic when decoding CLOSE frame

2021-09-12 15:35:49 -06:00

websocket.go

Updates based on code review

2021-09-13 14:06:17 -06:00