schema.graphql

scalar JSON

# input type
input PublishInput {
  type: String!
  scope: String
  payload: JSON
}
input SubscribeInput {
  type: String
  scope: String
}

# return type
type MessagePayload {
  type: String!
  scope: String
  payload: JSON
}

# Query types
type Query {
  messageBus: String
}
type Mutation {
  publish(message: PublishInput): MessagePayload
}
type Subscription {
  messages(filter: SubscribeInput): MessagePayload
}