My event subscribers will not continue to work after the same event once it is repeated. I've tried using skipRetained and retained. Event drop event but the only thing that seems to work is the dropAll() command.

Here is a portion of my code.

Poster

GlobalBus.post(FriendUpdatePayload(userSession.user.toPublic(), userSession.user.identifier, "state", UserState.ONLINE.ordinal))
GlobalBus.post(SelfUpdatePayload(userSession.user.toPublic(), "state", UserState.ONLINE.ordinal))

Subscriber

  events.subscribe<FriendUpdatePayload> { payload ->
            logger.info("Update Payload -> ${payload.id} ${payload.name} = ${payload.value}")
            connections.values.forEach { v -> println(v.user.identifier) }
            val friends = connections.values.find { u -> u.user.identifier== payload.id }!!.user.getFriends()
            for (friend in friends.friends) {
                val friendSession = connections.values.find { f -> f.user.identifier == friend.id }!!
                send(friendSession.ws.session, friendSession.ws.type, jsonStr = payload.toJSON())
            }
            GlobalBus.dropAll() // Doesn't get another event without this.
            return@subscribe
        }
        events.subscribe<SelfUpdatePayload> { payload ->
            logger.info("Self Update -> ${payload.self.id} ${payload.name} = ${payload.value}")
            val selfSocket = connections.values.find { u -> u.user.identifier == payload.self.id }
            if (selfSocket != null) {
                send(selfSocket.ws.session, selfSocket.ws.type, jsonStr = payload.toJSON())
            }
            GlobalBus.dropAll() // Doesn't get another event without this.
            return@subscribe
        }