NAMESPACE

import(methods)
import(futile.logger)
import(mongo)
importFrom("jsonlite", "base64_enc","base64_dec",
           "serializeJSON", "unserializeJSON")
importFrom("utils", "limitedLabels")


export(P4Message)
exportClasses(P4Message,MessageQueue,MongoQueue,ListQueue)
export(app,"app<-",uid,"uid<-",
       context,"context<-",
       timestamp,"timestamp<-",
       sender,"sender<-",mess,"mess<-",details,
       all.equal.P4Message,
       processed, markAsProcessed, processingError, markAsError,
       serializeData,fetchNextMessage,
       resetProcessedMessages,cleanMessageQueue,
       importMessages)
S3method(all.equal,P4Message,all.equal.P4Message)
exportMethods(app,"app<-",uid,"uid<-",context,"context<-",
              timestamp,"timestamp<-",sender,"sender<-",
              mess,"mess<-",details,"details<-",
              toString,show, processed, processingError,
              markAsProcessed, markAsError,
              resetProcessedMessages,cleanMessageQueue,
              importMessages)


export(buildMessage, cleanMessageJlist)
exportMethods("as.jlist","parse.jlist")

export(receiveMessage,isListener,ListenerSet,notifyListeners,
       listeningFor, clearMessages,
       InjectionListener,UpdateListener,UpsertListener,CaptureListener,
       TableListener, buildListener, listenerName, resetListeners,
       buildListenerSet, registerOutput, listenerDataTable,
       updateTable,generateListenerExports)
exportClasses(ListenerSet,NullListenerSet,RefListener,
       CaptureListener,InjectionListener,
       UpdateListener,UpsertListener,TableListener)
exportMethods(isListener,receiveMessage,notifyListeners,listenerName,
              resetListeners,clearMessages,listeningFor, registerOutput,
              listenerDataTable)

exportClasses(mongoAppender)
export(withFlogging,mongoAppender)