ghillert

14:47:32.498 WARN  [main][org.springframework.beans.GenericTypeAwarePropertyDescriptor] Invalid JavaBean property 'port' being accessed! Ambiguous write methods found next to actually used [public void net.xqj.basex.BaseXXQDataSource.setPort(java.lang.String)]: [public void net.xqj.basex.BaseXXQDataSource.setPort(int)]
java.lang.RuntimeException: The key "125" was not found in the Resouce Message Bundle.
	at net.xqj.basex.bin.aa.a(Unknown Source)
	at net.xqj.basex.bin.A.a(Unknown Source)
	at net.xqj.basex.bin.Z.a(Unknown Source)
	at net.xqj.basex.bin.c.<init>(Unknown Source)
	at net.xqj.basex.BaseXXQDataSource.getConnection(Unknown Source)
	at net.xqj.basex.bin.d.<clinit>(Unknown Source)
	at net.xqj.basex.BaseXXQDataSource.a(Unknown Source)
	at net.xqj.basex.BaseXXQDataSource.getConnection(Unknown Source)

ghillert

package org.springframework.xd.examples.hadoop;

import java.io.IOException;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

import org.apache.commons.lang.StringEscapeUtils;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.LongWritable;

ghillert

...
public class DevNexusApplication implements EmbeddedServletContainerCustomizer {
  ...
  @Override
  public void customize(ConfigurableEmbeddedServletContainer container) {
    if(container instanceof TomcatEmbeddedServletContainerFactory) {
      final TomcatEmbeddedServletContainerFactory tomcatEmbeddedServletContainerFactory
          = (TomcatEmbeddedServletContainerFactory) container;

      tomcatEmbeddedServletContainerFactory.addContextCustomizers(

ghillert

[
  {
    "latitude": 38.907774,
    "longitude": -77.023736,
    "address1": "1317 9th St NW",
    "city": "Washington",
    "state": "DC",
    "zip": "20001",
    "type": "Service"
  },

ghillert

Checkout, Build and Run UAA:

$ git clone https://github.com/cloudfoundry/uaa.git
$ cd uaa/
$ ./gradlew  run

In a separate window, check if the UAA server is running:

ghillert

Create a base directory where we store everything.

Requirements

• Make sure you use JDK8
• Git installed
• You need uaac installed - https://github.com/cloudfoundry/cf-uaac

In case you run into issues installing uaac, you may have to set

ghillert

<dependency>
  <groupId>com.oracle.coherence.spring</groupId>
  <artifactId>coherence-spring-boot-starter</artifactId>
  <version>3.0.0-M2</version>
</dependency>		
<dependency>
  <groupId>com.oracle.coherence.spring</groupId>
  <artifactId>coherence-spring-session</artifactId>
  <version>3.0.0-M2</version>
</dependency>

ghillert

spring:
  session:
    timeout: 15m
...
# The optional session management endpoint is suppored as well:
management:
  endpoint:
    sessions:
      enabled: true
  endpoints:

ghillert

@CoherencePublisher  
public interface ProductClient {
  
    @Topic("my-products") 
    void sendProduct(Product product);
  
}

ghillert

@CoherenceTopicListener
@Topic("my-products")
public void receive(Element<Product> product) {
    // ... process message ...
}