Code

MQTT Query Interface#461

Code

Open

NehaSelvan1512 wants to merge 115 commits intomasterpolypheny/Polypheny-DB:masterfrom mqtt-interfacepolypheny/Polypheny-DB:mqtt-interfaceCopy head branch name to clipboard

+2,885-46

Commits

Commits on Jun 5, 2023

• Add skeleton

  vogti

  committed
  5857938

Commits on Jun 12, 2023

• Added mqtt client dependency to gradle

  NehaSelvan1512

  committed
  ddb0b58

Commits on Jun 13, 2023

• coded the connection establishment to broker

  Show description for 1ccaa44
  NehaSelvan1512

  committed
  1ccaa44

Commits on Jun 16, 2023

• Implemented shutdown method

  NehaSelvan1512

  committed
  73ab690

• Implemented sub, unsub and pub methods

  Show description for 24936a2
  NehaSelvan1512

  committed
  24936a2

Commits on Jun 17, 2023

• Implemented MonitoringPage

  Show description for 2ccdf62
  NehaSelvan1512

  committed
  2ccdf62

• deleted security files

  Show description for 247892a
  NehaSelvan1512

  committed
  247892a

• Renamed Interface to Stream

  NehaSelvan1512

  committed
  c6d0d1b

Commits on Jun 18, 2023

• Resolved issues coming from name changing of classes

  NehaSelvan1512

  committed
  5a26572

Commits on Jun 20, 2023

• changed the mqtt client library

  Show description for 477ea76
  NehaSelvan1512

  committed
  477ea76

Commits on Jun 22, 2023

• added the mqtt client library version as variable

  Show description for 8721294
  NehaSelvan1512

  committed
  8721294

Commits on Jun 24, 2023

• implemented skeleton of StreamProcessing

  Show description for 2b888db
  NehaSelvan1512

  committed
  2b888db

Commits on Jun 25, 2023

• corrected minor things in processMsg method

  NehaSelvan1512

  committed
  ec4b9b1

• implemented registerTopicFolder and saveMsgInFile methods

  Show description for e4953dc
  NehaSelvan1512

  committed
  e4953dc

Commits on Jun 27, 2023

• implemented createCollection method

  Show description for 9684d69
  NehaSelvan1512

  committed
  9684d69

• resolved problem with inserting changed settings to map settings

  NehaSelvan1512

  committed
  f8b5559

• Reformatted code

  NehaSelvan1512

  committed
  27b96ba

Commits on Jun 29, 2023

• optimized and debugged reloadSettings method

  Show description for d5c93e4
  NehaSelvan1512

  committed
  d5c93e4

• created skeleton of class PolyStream

  Show description for 38035ff
  NehaSelvan1512

  committed
  38035ff

• added namespaces to createCollection

  Show description for 45fe6ed
  NehaSelvan1512

  committed
  45fe6ed

Commits on Jul 2, 2023

• implemented the process to get a collection

  Show description for 097d3a0
  NehaSelvan1512

  committed
  097d3a0

• added instance variables

  Show description for d487f91
  NehaSelvan1512

  committed
  d487f91

Commits on Jul 4, 2023

• started implementing saveContent

  Show description for 440400b
  NehaSelvan1512

  committed
  440400b

• added PolyStream and connected processMsg with StreamCapture class

  NehaSelvan1512

  committed
  85c96e0

• made changes in modifiers and new constructor

  NehaSelvan1512

  committed
  d6dd1bf

Commits on Jul 7, 2023

• resolved problem of changes in the settings not being permanently saved

  NehaSelvan1512

  committed
  b118f39

• Improve update settings fix

  vogti

  committed
  d7f48aa

• inserted option of using default databaseID and userID

  NehaSelvan1512

  committed
  e165e37

• added example for doc insert and scan, added dedicate methods in AlgBuilder

  datomo

  committed
  4b8e37a

• debugged namespace and collection creation logic

  Show description for 62b2553
  NehaSelvan1512

  committed
  62b2553

• improved trimming of topics coming from UI

  NehaSelvan1512

  committed
  2d46042

• Merge branch 'mqtt-interface' of https://github.com/polypheny/Polypheny-DB into mqtt-interface

  NehaSelvan1512

  committed
  66385ef

Commits on Jul 9, 2023

• added namespace and type handling

  Show description for 8a2801d
  NehaSelvan1512

  committed
  8a2801d

• fixed minor changes

  Show description for 3f8ab3c
  NehaSelvan1512

  committed
  3f8ab3c

Commits on Jul 11, 2023

• included MqttTopic objects

  Show description for 805a691
  NehaSelvan1512

  committed
  805a691

• debugging of reloadSettings method

  NehaSelvan1512

  committed
  9fe13b4

Commits on Jul 12, 2023

• Revert "debugging of reloadSettings method"

  Show description for e4e9d0b
  NehaSelvan1512

  committed
  e4e9d0b

• Revert "included MqttTopic objects"

  Show description for 68be5dd
  NehaSelvan1512

  committed
  68be5dd

Commits on Jul 13, 2023

• reverted changes made because of MqttTopic

  NehaSelvan1512

  committed
  adf1278

Commits on Jul 16, 2023

• Debugging of insertDocument ongoing

  NehaSelvan1512

  committed
  7ba81bc

• skeleton of StreamProcessing added

  NehaSelvan1512

  committed
  324409e

Commits on Jul 17, 2023

• fixed issue with insertDocument

  Show description for 608e7c6
  NehaSelvan1512

  committed
  608e7c6

• changed Module of MqttStreamProcessor

  NehaSelvan1512

  committed
  d7d94e2

• added StreamMessage to module stream

  Show description for 75956c0
  NehaSelvan1512

  committed
  75956c0

• added getStreamProcessor method

  NehaSelvan1512

  committed
  8220800

• integrated MqttMessage objects in existing code

  NehaSelvan1512

  committed
  7dedc4f

• Reformatted files

  NehaSelvan1512

  committed
  ff33451

• added EntityType STREAM

  NehaSelvan1512

  committed
  5a01216

• integrated MqttMessage objects in MqttStreamProcessor

  NehaSelvan1512

  committed
  2c0113d

Commits on Jul 18, 2023

• changed constructor parameter from TransactionManager to Transaction

  NehaSelvan1512

  committed
  0cc5df6

• change of StreamProcessorImpl constructor

  NehaSelvan1512

  committed
  e1bd401

• fixed accessing StreamProcessorImpl from MqttStreamProcessor

  NehaSelvan1512

  committed
  cd72d1c

• changed topics List to a ConcurrentHashMap

  Show description for 71bd1d7
  NehaSelvan1512

  committed
  71bd1d7

Commits on Jul 19, 2023

• Monitoring Page now shows recent messages

  NehaSelvan1512

  committed
  81b13a8

Commits on Jul 20, 2023

• added a reconnect button

  Show description for 5088320
  NehaSelvan1512

  committed
  5088320

• corrected code adding placements

  Show description for d777da6
  NehaSelvan1512

  committed
  d777da6

• moved creating collections to MqttInterface

  NehaSelvan1512

  committed
  52501f6

• implemented message count for each topic

  Show description for 04d1fee
  NehaSelvan1512

  committed
  04d1fee

Commits on Jul 21, 2023

• implemented a option to save all messages in one collection

  NehaSelvan1512

  committed
  c017cac

• imploved Monitoring Page

  NehaSelvan1512

  committed
  599f418

• small fixes

  NehaSelvan1512

  committed
  add043a

Commits on Jul 27, 2023

• minor fixes and reformatted file

  Show description for 7671e87
  NehaSelvan1512

  committed
  7671e87

• Minor fixes

  Show description for db2757f
  NehaSelvan1512

  committed
  db2757f

• made both classes independent of ids

  NehaSelvan1512

  committed
  b0fe5d0

Commits on Jul 28, 2023

• debugging

  NehaSelvan1512

  committed
  40a6cd7

• inserted field source

  NehaSelvan1512

  committed
  f3cda56

Commits on Jul 29, 2023

• added function to create all necessary collections in reload method

  NehaSelvan1512

  committed
  97a9d9f

• implemented queue for messages

  NehaSelvan1512

  committed
  a88e584

• resolving concurrency

  Show description for 8138aca
  NehaSelvan1512

  committed
  8138aca

Commits on Jul 30, 2023

• Minor fix

  Show description for 4fdeeb2
  NehaSelvan1512

  committed
  4fdeeb2

• deleted unused methods

  NehaSelvan1512

  committed
  54b0993

Commits on Aug 7, 2023

• ssl code added but commented

  NehaSelvan1512

  committed
  8a5a9c8

• comment ssl conn code

  NehaSelvan1512

  committed
  76c8e34

• integrated universal lock for concurrency

  NehaSelvan1512

  committed
  15687e2

Commits on Aug 31, 2023

• started testing environment

  NehaSelvan1512

  committed
  4ea38ff

Commits on Sep 3, 2023

• StreamProcessor in progress

  NehaSelvan1512

  committed
  af47b78

• minor changes

  NehaSelvan1512

  committed
  32dc64e

Commits on Sep 4, 2023

• fixed test and filtering

  datomo

  committed
  db647fe

Commits on Sep 5, 2023

• changed ModelTrait to Document

  NehaSelvan1512

  committed
  8b2c078

• changed structure of convert method & added '$$ROOT' as operator

  NehaSelvan1512

  committed
  e49b725

Commits on Sep 8, 2023

• finished implementing and testing

  NehaSelvan1512

  committed
  202d39a

• Deleted PolyStream class

  NehaSelvan1512

  committed
  2d5628f

• reformatted code

  NehaSelvan1512

  committed
  2380174

Commits on Sep 10, 2023

• made various changes

  Show description for 38b1528
  NehaSelvan1512

  committed
  38b1528

• cleaned up code

  NehaSelvan1512

  committed
  baf6eb3

• added mockito

  NehaSelvan1512

  committed
  da2f9c8

Commits on Sep 12, 2023

• various changes, see description

  Show description for 6075479
  NehaSelvan1512

  committed
  6075479

Commits on Sep 13, 2023

• MQTT version 5, create topic collection in constructor, added automatic reconnect

  NehaSelvan1512

  committed
  db22a1d

Commits on Sep 15, 2023

• Debugging with Unit tests and added Qos

  Show description for 11302ba
  NehaSelvan1512

  committed
  11302ba

• testing and debugging

  NehaSelvan1512

  committed
  1ef13a8

• minor change at prefix for query

  NehaSelvan1512

  committed
  ce068fc

Commits on Sep 24, 2023

• last time pushing multiple changes at once!!

  NehaSelvan1512

  committed
  e3042b4

Commits on Sep 25, 2023

• fixed find with boolean

  NehaSelvan1512

  committed
  d763c08

• defined Helper class for StreamCapture testing

  NehaSelvan1512

  committed
  d24a242

• changed variable name message -> payload

  NehaSelvan1512

  committed
  5610f8f

Commits on Sep 27, 2023

• Debugged code while testing stream capture + mqttClient component

  NehaSelvan1512

  committed
  c359ddf

Commits on Sep 28, 2023

• added getter to topicsMap

  NehaSelvan1512

  committed
  f70e933

• added workflow for testing a broker in container

  NehaSelvan1512

  committed
  a13c18d

• changed version

  NehaSelvan1512

  committed
  f413f11

Commits on Sep 29, 2023

• renamed variable

  NehaSelvan1512

  committed
  e4b66cc

• removed unnecessary code

  NehaSelvan1512

  committed
  60ee769

• Tests for sub + wildcards and unsub

  NehaSelvan1512

  committed
  e834f56

• removed methods related to ssl

  NehaSelvan1512

  committed
  64c8bcd

• inserted tests for verifying collection creation

  NehaSelvan1512

  committed
  9b9a570

• added getWildcard and catchAllEntity=false tests

  NehaSelvan1512

  committed
  38067a5

• renamed methods and vars

  Show description for a1bc339
  NehaSelvan1512

  committed
  a1bc339

• inserted query for namespace type

  NehaSelvan1512

  committed
  68431a7

• fixed dependency problem

  NehaSelvan1512

  committed
  6b100d9

• minor changes

  NehaSelvan1512

  committed
  9a34ee8

• reformatted files

  NehaSelvan1512

  committed
  9689011

Commits on Sep 30, 2023

• changed test method name and made few modifications

  NehaSelvan1512

  committed
  f14cb74

Commits on Oct 8, 2023

• fixed mistake in UI

  NehaSelvan1512

  committed
  7e524ad

• removed forgotten logger

  NehaSelvan1512

  committed
  002b814

Commits on Oct 16, 2023

• cleaned up code

  NehaSelvan1512

  committed
  5c3723e

Commits on Oct 17, 2023

• removed code related to stream entity

  NehaSelvan1512

  committed
  15ee90f