Connection

@Conn("AUTHORED")
public class AuthoredConnection extends Connection<BookDE, AuthorDE>{
  public AuthoredConnection() {
  }

  public AuthoredConnection(AuthorDE from, BookDE to) {
    super(from, to);
  }

  public AuthoredConnection(AuthorDE from, BookDE to, Map<String, String> metadata) {
    super(from, to, metadata);
  }
}

Connection

public class AuthoredConnection extends Connection<BookDE, AuthorDE>{

In the example above the AuthorDE is pointing to BookDE in a OneToMany relationship

@Conn(name)

Configures the name of the connection and the topic name used in MQS.