This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package com.bala.custom.wih; | |
import java.util.HashMap; | |
import java.util.Map; | |
import org.kie.api.runtime.process.WorkItem; | |
import org.kie.api.runtime.process.WorkItemHandler; | |
import org.kie.api.runtime.process.WorkItemManager; | |
public class CustomWIH implements WorkItemHandler { |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
time="2019-02-15T06:07:00Z" level=debug msg="Fetching \"Terraform Variables\"..." | |
time="2019-02-15T06:07:00Z" level=debug msg="Loading \"Terraform Variables\"..." | |
time="2019-02-15T06:07:00Z" level=debug msg=" Loading \"Cluster ID\"..." | |
time="2019-02-15T06:07:00Z" level=debug msg=" Loading \"Install Config\"..." | |
time="2019-02-15T06:07:00Z" level=debug msg=" Loading \"SSH Key\"..." | |
time="2019-02-15T06:07:00Z" level=debug msg=" Loading \"Base Domain\"..." | |
time="2019-02-15T06:07:00Z" level=debug msg=" Loading \"Platform\"..." | |
time="2019-02-15T06:07:00Z" level=debug msg=" Loading \"Cluster Name\"..." | |
time="2019-02-15T06:07:00Z" level=debug msg=" Loading \"Base Domain\"..." | |
time="2019-02-15T06:07:00Z" level=debug msg=" Loading \"Pull Secret\"..." |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
time="2019-02-25T04:08:51Z" level=debug msg="Fetching \"Install Config\"..." | |
time="2019-02-25T04:08:51Z" level=debug msg="Loading \"Install Config\"..." | |
time="2019-02-25T04:08:51Z" level=debug msg=" Loading \"SSH Key\"..." | |
time="2019-02-25T04:08:51Z" level=debug msg=" Loading \"Base Domain\"..." | |
time="2019-02-25T04:08:51Z" level=debug msg=" Loading \"Platform\"..." | |
time="2019-02-25T04:08:51Z" level=debug msg=" Loading \"Cluster Name\"..." | |
time="2019-02-25T04:08:51Z" level=debug msg=" Loading \"Pull Secret\"..." | |
time="2019-02-25T04:08:51Z" level=debug msg=" Loading \"Platform\"..." | |
time="2019-02-25T04:08:51Z" level=debug msg=" Fetching \"SSH Key\"..." | |
time="2019-02-25T04:08:51Z" level=debug msg=" Generating \"SSH Key\"..." |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package com.bala.custom.wih; | |
import java.util.ArrayList; | |
import java.util.List; | |
import javax.xml.bind.JAXBException; | |
import javax.xml.namespace.QName; | |
import org.apache.cxf.endpoint.Client; | |
import org.apache.cxf.headers.Header; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package com.bala.custom.wih; | |
import java.util.ArrayList; | |
import java.util.List; | |
import javax.xml.bind.JAXBException; | |
import javax.xml.namespace.QName; | |
import org.apache.cxf.endpoint.Client; | |
import org.apache.cxf.headers.Header; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package com.bala.rhpam.test; | |
import java.net.HttpURLConnection; | |
import java.net.URL; | |
import java.util.concurrent.ExecutorService; | |
import java.util.concurrent.Executors; | |
public class ConcurrentHTTPGetStatusLogger { | |
private static final int MYTHREADS = 700; | |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package com.bmi.calc; | |
/** | |
* This class was automatically generated by the data modeler tool. | |
*/ | |
import java.io.Serializable; | |
import java.time.LocalDateTime; | |
import org.kie.api.definition.type.Label; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
# camel twitter search config | |
camel.component.twitter-search.consumerKey=xxxxxYyfr2o9mxaay4 | |
camel.component.twitter-search.consumerSecret=xxxxxxxxxxfOdhNqGE8EGVC6pKmDpfEJe1V6 | |
camel.component.twitter-search.accessToken=xxxxxxx-44ZwHxl6zTWz0xO4Jh4qJKdyZMw | |
camel.component.twitter-search.accessTokenSecret=xxxxxxSW1ojFqOW7nT4W7frzNladZUUWpd2a |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
@Path("/twitter") | |
@ApplicationScoped | |
public class CamelResource { | |
final Logger LOG = Logger.getLogger(CamelResource.class); | |
String twitterSearchUri = "twitter-search://#" + "$$TOPIC" + "?count=10&lang=en-us"; | |
@Inject | |
@Channel("twitter-feeds") | |
Emitter<Feed> emitter; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
# kafka twitter-feeds config | |
mp.messaging.outgoing.twitter-feeds.bootstrap.servers=localhost:9092 | |
mp.messaging.outgoing.twitter-feeds.connector=smallrye-kafka | |
mp.messaging.outgoing.twitter-feeds.key.serializer=org.apache.kafka.common.serialization.StringSerializer | |
mp.messaging.outgoing.twitter-feeds.value.serializer=com.redhat.hackfest.serializers.FeedSerializer |
OlderNewer