File tree Expand file tree Collapse file tree 4 files changed +46
-23
lines changed
src/integrationTest/java/com/hivemq/extensions/heartbeat Expand file tree Collapse file tree 4 files changed +46
-23
lines changed Original file line number Diff line number Diff line change 36
36
optionalCredentials()
37
37
}
38
38
}
39
+ imageMapping {
40
+ mapModule(" com.hivemq" , " hivemq-community-edition" ) {
41
+ toImage(" hivemq/hivemq-ce" )
42
+ }
43
+ }
44
+ imageDefinitions.register(" main" ) {
45
+ allPlatforms {
46
+ dependencies {
47
+ runtime(" com.hivemq:hivemq-community-edition:latest" ) { isChanging = true }
48
+ }
49
+ config {
50
+ ports = setOf (" 9090" )
51
+ }
52
+ layers {
53
+ layer(" hivemqExtension" ) {
54
+ contents {
55
+ permissions(" opt/hivemq/" , 0b111_111_000 )
56
+ permissions(" opt/hivemq/extensions/" , 0b111_111_000 )
57
+ into(" opt/hivemq/extensions" ) {
58
+ from(zipTree(tasks.hivemqExtensionZip.flatMap { it.archiveFile }))
59
+ }
60
+ }
61
+ }
62
+ }
63
+ }
64
+ }
39
65
}
40
66
41
67
@Suppress(" UnstableApiUsage" )
@@ -62,7 +88,7 @@ testing {
62
88
}
63
89
oci.of(this ) {
64
90
imageDependencies {
65
- runtime(" hivemq:hivemq-ce: latest" ) { isChanging = true }
91
+ runtime(project).tag( " latest" )
66
92
}
67
93
}
68
94
}
Original file line number Diff line number Diff line change 41
41
class CustomConfigIT {
42
42
43
43
@ Container
44
- final @ NotNull HiveMQContainer hivemq = new HiveMQContainer (OciImages .getImageName ("hivemq/hivemq-ce" )) //
45
- .withExtension (MountableFile .forClasspathResource ("hivemq-heartbeat-extension" ))
46
- .waitForExtension ("HiveMQ Heartbeat Extension" )
47
- .withExposedPorts (9191 )
48
- .withFileInExtensionHomeFolder (MountableFile .forClasspathResource ("extension-config.xml" ),
49
- "hivemq-heartbeat-extension" ,
50
- "/extension-config.xml" )
51
- .withLogConsumer (outputFrame -> System .out .print ("HiveMQ: " + outputFrame .getUtf8String ()));
44
+ final @ NotNull HiveMQContainer hivemq =
45
+ new HiveMQContainer (OciImages .getImageName ("hivemq/extensions/hivemq-heartbeat-extension" )
46
+ .asCompatibleSubstituteFor ("hivemq/hivemq-ce" )) //
47
+ .withExposedPorts (9191 )
48
+ .withCopyToContainer (MountableFile .forClasspathResource ("extension-config.xml" ),
49
+ "/opt/hivemq/extensions/hivemq-heartbeat-extension/extension-config.xml" )
50
+ .withLogConsumer (outputFrame -> System .out .print ("HiveMQ: " + outputFrame .getUtf8String ()));
52
51
53
52
@ Test
54
53
@ Timeout (value = 2 , unit = TimeUnit .MINUTES )
Original file line number Diff line number Diff line change 26
26
import org .testcontainers .hivemq .HiveMQContainer ;
27
27
import org .testcontainers .junit .jupiter .Container ;
28
28
import org .testcontainers .junit .jupiter .Testcontainers ;
29
- import org .testcontainers .utility .MountableFile ;
30
29
31
30
import java .util .concurrent .TimeUnit ;
32
31
41
40
class DefaultConfigIT {
42
41
43
42
@ Container
44
- final @ NotNull HiveMQContainer hivemq = new HiveMQContainer ( OciImages . getImageName ( "hivemq/hivemq-ce" )) //
45
- . withExtension ( MountableFile . forClasspathResource ("hivemq-heartbeat-extension" ) )
46
- . waitForExtension ( "HiveMQ Heartbeat Extension" )
47
- .withExposedPorts (9090 )
48
- .withLogConsumer (outputFrame -> System .out .print ("HiveMQ: " + outputFrame .getUtf8String ()));
43
+ final @ NotNull HiveMQContainer hivemq =
44
+ new HiveMQContainer ( OciImages . getImageName ("hivemq/extensions/hivemq -heartbeat-extension" )
45
+ . asCompatibleSubstituteFor ( "hivemq/hivemq-ce" )) //
46
+ .withExposedPorts (9090 )
47
+ .withLogConsumer (outputFrame -> System .out .print ("HiveMQ: " + outputFrame .getUtf8String ()));
49
48
50
49
@ Test
51
50
@ Timeout (value = 2 , unit = TimeUnit .MINUTES )
Original file line number Diff line number Diff line change 41
41
class FallbackToDefaultsIT {
42
42
43
43
@ Container
44
- final @ NotNull HiveMQContainer hivemq = new HiveMQContainer (OciImages .getImageName ("hivemq/hivemq-ce" )) //
45
- .withExtension (MountableFile .forClasspathResource ("hivemq-heartbeat-extension" ))
46
- .waitForExtension ("HiveMQ Heartbeat Extension" )
47
- .withExposedPorts (9090 )
48
- .withFileInExtensionHomeFolder (MountableFile .forClasspathResource ("broken-config.xml" ),
49
- "hivemq-heartbeat-extension" ,
50
- "/extension-config.xml" )
51
- .withLogConsumer (outputFrame -> System .out .print ("HiveMQ: " + outputFrame .getUtf8String ()));
44
+ final @ NotNull HiveMQContainer hivemq =
45
+ new HiveMQContainer (OciImages .getImageName ("hivemq/extensions/hivemq-heartbeat-extension" )
46
+ .asCompatibleSubstituteFor ("hivemq/hivemq-ce" )) //
47
+ .withExposedPorts (9090 )
48
+ .withCopyToContainer (MountableFile .forClasspathResource ("broken-config.xml" ),
49
+ "/opt/hivemq/extensions/hivemq-heartbeat-extension/extension-config.xml" )
50
+ .withLogConsumer (outputFrame -> System .out .print ("HiveMQ: " + outputFrame .getUtf8String ()));
52
51
53
52
@ Test
54
53
@ Timeout (value = 2 , unit = TimeUnit .MINUTES )
You can’t perform that action at this time.
0 commit comments