Skip to content

Commit 8cf563d

Browse files
fax4everfax4ever
committed
OCP-DEMO Add Infinispan Server Task
1 parent ac69bf0 commit 8cf563d

File tree

13 files changed

+601
-0
lines changed

13 files changed

+601
-0
lines changed

‎openshift/message-board/extra/message-server-task/pom.xml

Lines changed: 48 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,48 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<project xmlns="http://maven.apache.org/POM/4.0.0"
3+
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
5+
<modelVersion>4.0.0</modelVersion>
6+
<parent>
7+
<groupId>org.hibernate.demos.messageboard</groupId>
8+
<artifactId>extra</artifactId>
9+
<version>1.0.0-SNAPSHOT</version>
10+
</parent>
11+
12+
<artifactId>message-server-task</artifactId>
13+
<packaging>jar</packaging>
14+
15+
<properties>
16+
<!-- taken from hibernate-ogm-bom-5.4.0.Beta2 -->
17+
<!-- when update OGM version on message, update this version too -->
18+
<version.org.infinispan>9.3.0.Final</version.org.infinispan>
19+
20+
<!-- taken from wildfly-bom-13 -->
21+
<!-- when update Wildfly version on message, update this version too -->
22+
<version.slf4j>1.7.22</version.slf4j>
23+
</properties>
24+
25+
<dependencies>
26+
<dependency>
27+
<groupId>org.infinispan</groupId>
28+
<artifactId>infinispan-tasks</artifactId>
29+
<version>${version.org.infinispan}</version>
30+
<scope>provided</scope>
31+
</dependency>
32+
33+
<dependency>
34+
<groupId>org.infinispan</groupId>
35+
<artifactId>infinispan-remote-query-server</artifactId>
36+
<version>${version.org.infinispan}</version>
37+
<scope>provided</scope>
38+
</dependency>
39+
40+
<dependency>
41+
<groupId>org.slf4j</groupId>
42+
<artifactId>slf4j-api</artifactId>
43+
<version>${version.slf4j}</version>
44+
<scope>provided</scope>
45+
</dependency>
46+
</dependencies>
47+
48+
</project>

‎openshift/message-board/extra/message-server-task/src/main/java/it/redhat/demo/model/Board.java

Lines changed: 53 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,53 @@
1+
package it.redhat.demo.model;
2+
3+
import java.io.IOException;
4+
5+
import org.infinispan.protostream.MessageMarshaller;
6+
7+
public class Board {
8+
9+
public static final String CACHE_NAME = Board.class.getSimpleName();
10+
11+
private String username;
12+
13+
public Board() {
14+
}
15+
16+
public Board(String username) {
17+
this.username = username;
18+
}
19+
20+
/*
21+
* package HibernateOGMGenerated;
22+
*
23+
* message Board {
24+
* required string username = 1;
25+
* }
26+
*
27+
*/
28+
public static final class Marshaller implements MessageMarshaller<Board> {
29+
30+
@Override
31+
public Board readFrom(ProtoStreamReader reader) throws IOException {
32+
Board board = new Board();
33+
board.username = reader.readString( "username" );
34+
35+
return board;
36+
}
37+
38+
@Override
39+
public void writeTo(ProtoStreamWriter writer, Board board) throws IOException {
40+
writer.writeString( "username", board.username );
41+
}
42+
43+
@Override
44+
public Class<? extends Board> getJavaClass() {
45+
return Board.class;
46+
}
47+
48+
@Override
49+
public String getTypeName() {
50+
return "HibernateOGMGenerated.Board";
51+
}
52+
}
53+
}

‎openshift/message-board/extra/message-server-task/src/main/java/it/redhat/demo/model/BoardId.java

Lines changed: 77 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,77 @@
1+
package it.redhat.demo.model;
2+
3+
import java.io.IOException;
4+
import java.util.Objects;
5+
6+
import org.infinispan.protostream.MessageMarshaller;
7+
8+
public class BoardId {
9+
10+
private String username;
11+
12+
public BoardId() {
13+
}
14+
15+
public BoardId(String username) {
16+
this.username = username;
17+
}
18+
19+
@Override
20+
public boolean equals(Object o) {
21+
if ( this == o ) {
22+
return true;
23+
}
24+
if ( o == null || getClass() != o.getClass() ) {
25+
return false;
26+
}
27+
BoardId boardId = (BoardId) o;
28+
return Objects.equals( username, boardId.username );
29+
}
30+
31+
@Override
32+
public int hashCode() {
33+
return Objects.hash( username );
34+
}
35+
36+
@Override
37+
public String toString() {
38+
final StringBuilder sb = new StringBuilder( "BoardId{" );
39+
sb.append( "username='" ).append( username ).append( '\'' );
40+
sb.append( '}' );
41+
return sb.toString();
42+
}
43+
44+
/*
45+
* package HibernateOGMGenerated;
46+
*
47+
* message Board_id {
48+
* required string username = 1;
49+
* }
50+
*
51+
*/
52+
public static final class Marshaller implements MessageMarshaller<BoardId> {
53+
54+
@Override
55+
public BoardId readFrom(ProtoStreamReader reader) throws IOException {
56+
BoardId boardId = new BoardId();
57+
boardId.username = reader.readString( "username" );
58+
59+
return boardId;
60+
}
61+
62+
@Override
63+
public void writeTo(ProtoStreamWriter writer, BoardId board) throws IOException {
64+
writer.writeString( "username", board.username );
65+
}
66+
67+
@Override
68+
public Class<? extends BoardId> getJavaClass() {
69+
return BoardId.class;
70+
}
71+
72+
@Override
73+
public String getTypeName() {
74+
return "HibernateOGMGenerated.BoardId";
75+
}
76+
}
77+
}

‎openshift/message-board/extra/message-server-task/src/main/java/it/redhat/demo/model/BoardMessage.java

Lines changed: 63 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,63 @@
1+
package it.redhat.demo.model;
2+
3+
import java.io.IOException;
4+
5+
import org.infinispan.protostream.MessageMarshaller;
6+
7+
public class BoardMessage {
8+
9+
public static final String CACHE_NAME = BoardMessage.class.getSimpleName();
10+
11+
private String boardUsername;
12+
private Long messagesId;
13+
private Integer order;
14+
15+
public BoardMessage() {
16+
}
17+
18+
public BoardMessage(String boardUsername, Long messagesId, Integer order) {
19+
this.boardUsername = boardUsername;
20+
this.messagesId = messagesId;
21+
this.order = order;
22+
}
23+
24+
/*
25+
* package HibernateOGMGenerated;
26+
*
27+
* message Board_Message {
28+
* required string Board_username = 1;
29+
* optional int64 messages_id = 2;
30+
* required int32 order = 3;
31+
* }
32+
*
33+
*/
34+
public static final class Marshaller implements MessageMarshaller<BoardMessage> {
35+
36+
@Override
37+
public BoardMessage readFrom(ProtoStreamReader reader) throws IOException {
38+
BoardMessage boardMessage = new BoardMessage();
39+
boardMessage.boardUsername = reader.readString( "Board_username" );
40+
boardMessage.messagesId = reader.readLong( "messages_id" );
41+
boardMessage.order = reader.readInt( "order" );
42+
43+
return boardMessage;
44+
}
45+
46+
@Override
47+
public void writeTo(ProtoStreamWriter writer, BoardMessage boardMessage) throws IOException {
48+
writer.writeString( "Board_username", boardMessage.boardUsername );
49+
writer.writeLong( "messages_id", boardMessage.messagesId );
50+
writer.writeInt( "order", boardMessage.order );
51+
}
52+
53+
@Override
54+
public Class<? extends BoardMessage> getJavaClass() {
55+
return BoardMessage.class;
56+
}
57+
58+
@Override
59+
public String getTypeName() {
60+
return "HibernateOGMGenerated.Board_Message";
61+
}
62+
}
63+
}

‎openshift/message-board/extra/message-server-task/src/main/java/it/redhat/demo/model/BoardMessageId.java

Lines changed: 56 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,56 @@
1+
package it.redhat.demo.model;
2+
3+
import java.io.IOException;
4+
5+
import org.infinispan.protostream.MessageMarshaller;
6+
7+
public class BoardMessageId {
8+
9+
private String boardUsername;
10+
private Integer order;
11+
12+
public BoardMessageId() {
13+
}
14+
15+
public BoardMessageId(String boardUsername, Integer order) {
16+
this.boardUsername = boardUsername;
17+
this.order = order;
18+
}
19+
20+
/*
21+
* package HibernateOGMGenerated;
22+
*
23+
* message Board_Message_id {
24+
* required string Board_username = 1;
25+
* required int32 order = 2;
26+
* }
27+
*
28+
*/
29+
public static final class Marshaller implements MessageMarshaller<BoardMessageId> {
30+
31+
@Override
32+
public BoardMessageId readFrom(ProtoStreamReader reader) throws IOException {
33+
BoardMessageId boardMessageId = new BoardMessageId();
34+
boardMessageId.boardUsername = reader.readString( "Board_username" );
35+
boardMessageId.order = reader.readInt( "order" );
36+
37+
return boardMessageId;
38+
}
39+
40+
@Override
41+
public void writeTo(ProtoStreamWriter writer, BoardMessageId boardMessage) throws IOException {
42+
writer.writeString( "Board_username", boardMessage.boardUsername );
43+
writer.writeInt( "order", boardMessage.order );
44+
}
45+
46+
@Override
47+
public Class<? extends BoardMessageId> getJavaClass() {
48+
return BoardMessageId.class;
49+
}
50+
51+
@Override
52+
public String getTypeName() {
53+
return "HibernateOGMGenerated.Board_Message_id";
54+
}
55+
}
56+
}

‎openshift/message-board/extra/message-server-task/src/main/java/it/redhat/demo/model/Message.java

Lines changed: 62 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,62 @@
1+
package it.redhat.demo.model;
2+
3+
import java.io.IOException;
4+
5+
import org.infinispan.protostream.MessageMarshaller;
6+
7+
public class Message {
8+
9+
public static final String CACHE_NAME = Message.class.getSimpleName();
10+
11+
private Long id;
12+
private String body;
13+
private Long moment;
14+
private String username;
15+
16+
public String getUsername() {
17+
return username;
18+
}
19+
20+
/*
21+
* package HibernateOGMGenerated;
22+
*
23+
* message Message {
24+
* required int64 id = 1;
25+
* optional string body = 2;
26+
* optional int64 moment = 3;
27+
* optional string username = 4;
28+
* }
29+
*
30+
*/
31+
public static final class Marshaller implements MessageMarshaller<Message> {
32+
33+
@Override
34+
public Message readFrom(ProtoStreamReader reader) throws IOException {
35+
Message message = new Message();
36+
message.id = reader.readLong( "id" );
37+
message.body = reader.readString( "body" );
38+
message.moment = reader.readLong( "moment" );
39+
message.username = reader.readString( "username" );
40+
41+
return message;
42+
}
43+
44+
@Override
45+
public void writeTo(ProtoStreamWriter writer, Message messageId) throws IOException {
46+
writer.writeLong( "id", messageId.id );
47+
writer.writeString( "body", messageId.body );
48+
writer.writeLong( "moment", messageId.moment );
49+
writer.writeString( "username", messageId.username );
50+
}
51+
52+
@Override
53+
public Class<? extends Message> getJavaClass() {
54+
return Message.class;
55+
}
56+
57+
@Override
58+
public String getTypeName() {
59+
return "HibernateOGMGenerated.Message";
60+
}
61+
}
62+
}

0 commit comments

Comments
 (0)