David Navarro davengeo

🏠

Working from home

=====================

davengeo / FileTransferScpImpl.java

Last active November 12, 2015 18:07

SFTP transmission of content using apache VFS2 and OpenSSH private key


	@Component
	public class FileTransferScpImpl {


	private final String userName;
	private final String hostName;
	private final FileSystemOptions opts;
	private final StandardFileSystemManager manager;
	private final String privateKeyPath;

davengeo / TestRxStreamble.java

Last active October 27, 2015 13:54

Testing artefact for TDD with Rx Observables

	/*
	* Copyright (c) 2015.
	* David Navarro
	* [email protected]
	*/

	public class TestRxStreamble implements Streamable<EventContainer> {

	private static Logger LOG = LoggerFactory.getLogger(TestRxStreamble.class);

davengeo / RxInOutAspect.java

Created October 24, 2015 10:40

Aspect that propagates the argument of the advised methods as Observable, it might also propagate the result or the time elapsed

	/*
	* Copyright (c) 2015.
	* [email protected]
	*/

	package org.daven.demo.rxcache;

	import org.aspectj.lang.ProceedingJoinPoint;
	import org.aspectj.lang.annotation.Around;
	import org.aspectj.lang.annotation.Aspect;

davengeo / CacheStream.java

Last active October 19, 2015 21:07

Observable Stream created from Infinispan Cache

	/*
	* Copyright (c) 2015.
	* [email protected]
	*/

	package org.daven.demo.rxcache;

	import org.infinispan.Cache;
	import org.infinispan.manager.DefaultCacheManager;
	import org.infinispan.notifications.Listener;

davengeo / EventController.java

Last active October 18, 2015 17:53

RestController that emits as Observable

	/*
	* Copyright (c) 2015.
	* [email protected]
	*/

	package org.daven.demo.rxcache;

	import org.slf4j.Logger;
	import org.slf4j.LoggerFactory;
	import org.springframework.http.HttpEntity;

davengeo / LoggingAspect.java

Last active October 18, 2015 17:30

Aspect for profile methods

	/*
	* Copyright (c) 2015.
	* [email protected]
	*/

	package com.daven.aspects;

	import com.google.common.base.Stopwatch;
	import org.aspectj.lang.ProceedingJoinPoint;
	import org.aspectj.lang.annotation.Around;

davengeo / JmsListener.java

Last active October 12, 2015 09:19

much better now as hot observable

	/*
	* Copyright (c) 2015.
	* [email protected]
	*/

	package org.daven.rx.listeners;

	import org.daven.rx.domain.EventContainer;
	import org.slf4j.Logger;
	import org.slf4j.LoggerFactory;